package com.vci.server.query.service;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import org.hibernate.SQLQuery;
import org.hibernate.Session;

import com.vci.omd.constants.BusinessConstants;
import com.vci.omd.constants.LinkConstants;
import com.vci.server.base.exception.ExceptionLocalHandler;
import com.vci.server.base.persistence.dao.HibernateSessionFactory;
import com.vci.server.base.utility.OmdHelper;
import com.vci.server.cache.OMCacheProvider;
import com.vci.server.query.parsers.Parser;
import com.vci.server.query.util.QTSqlUtil;
import com.vci.corba.omd.data.AttributeValue;
import com.vci.corba.omd.data.BusinessObject;
import com.vci.corba.omd.data.LinkObject;
import com.vci.corba.omd.ltm.LinkType;
import com.vci.corba.query.data.BOAndLO;
import com.vci.common.exception.VciExceptionTool;
import com.vci.common.qt.object.QTConstants;
import com.vci.common.qt.object.QueryTemplate;
import com.vci.common.qt.object.Version;
import com.vci.corba.common.VCIError;

/**
 * 分段策略查询
 * 当链接查询多个业务类型时， 为满足递归查询实行二次查询：第一次查询link表，第二次分段查询btm表
 * @author zhouhui
 *
 */
public class QueryObjectPartationStrategy{
	
	private final int PARTIONSIZE = 500;
	private static QueryObjectPartationStrategy queryObj = null;
	
	private VCIError getLocalVciError(String key, Throwable e) {
		VCIError error = new VCIError(key, new String[]{VciExceptionTool.getExceptionStr(e), VciExceptionTool.getExceptionDetail(e)});
		VCIError rsError = ExceptionLocalHandler.getInstance().getLocalString(error, "PLMOQ");
		return rsError;
	}
	
	public static QueryObjectPartationStrategy getInstance(){
		if(queryObj == null){
			queryObj = new QueryObjectPartationStrategy();
		}
		return queryObj;
	}
	/**
	 * 解析QueryTemplate 为sql
	 * 执行sql, 返回结果
	 * @param queryTemplate
	 * @return
	 * @throws Throwable 
	 */
	public List<BusinessObject> findBtmObjects(QueryTemplate queryTemplate) throws Throwable{
		List<String> clauseList = queryTemplate.getClauseList();
		// 当clauseList中含有*时, 应当解析为BtmObject的全部属性
		if (clauseList.contains("*") || queryTemplate.isQueryChildren()) {
			clauseList = getAllAbNamesForBtm(queryTemplate.getBtmType());
		}
		queryTemplate.setClauseList(clauseList);
		Parser parser = new Parser(queryTemplate);
		String sql = parser.parseToSql();
		List<BusinessObject> objList = executeSqlForBtm(clauseList, sql);
		return objList;
	}
	
	/**
	 * @param clauseList
	 * @param sql
	 * @return
	 */
	private List<BusinessObject> executeSqlForBtm(List<String> clauseList, String sql){
		List<BusinessObject> objList = new ArrayList<BusinessObject>();
		Session session = HibernateSessionFactory.getSession();
		SQLQuery sqlquery = session.createSQLQuery(sql);
		//根据查询模板中的查询列clauseList, 设置map
		List<?> list = sqlquery.list();
		for(int i = 0; i < list.size(); i++){
			BusinessObject bo = new BusinessObject();
			AttributeValue[] abArray = null;
			//当list.get(i)中有多个Object时, 类型为Object[]
			//必须先判断Object[] 再判断Object
//			if((list.get(i)) instanceof Object[]){
				Object[] objs = (Object[])list.get(i);
				abArray = new AttributeValue[clauseList.size()];
				for(int k = 0; k < clauseList.size(); k++){
					AttributeValue ab = new AttributeValue();
					//sessin查询出的值
					Object obj_ = objs[k];
					//clauseList中对应的查询列
					String abName = clauseList.get(k);
					ab.attrName = abName;
					ab.attrVal = String.valueOf(obj_ == null ? "" : obj_);
					abArray[k] = ab;
				}
				
			//当list.get(i)中只有一个Object时, 类型为Object
//			}else{
				//sessin查询出的值
//				Object obj_ = list.get(i);
				//clauseList中对应的查询列
//				String abName = clauseList.get(0);
//				abArray = new AttributeValue[1];
//				AttributeValue ab = new AttributeValue();
//				ab.attrName = abName;
//				ab.attrVal = String.valueOf(obj_ == null ? "" : obj_);
//				abArray[0] = ab;
//				
//			}
			
			bo.newAttrValList = new AttributeValue[0];
			bo.hisAttrValList = abArray;
			//为btm的系统属性赋值
			int k = 0;
			bo.oid = abArray[k++].attrVal;
			bo.revisionid = abArray[k++].attrVal;
			bo.nameoid = abArray[k++].attrVal;
			bo.btName = abArray[k++].attrVal;
			bo.isLastR = Short.parseShort(abArray[k++].attrVal) != 0;
			bo.isFirstR = Short.parseShort(abArray[k++].attrVal) != 0;
			bo.isLastV = Short.parseShort(abArray[k++].attrVal) != 0;
			bo.isFirstV = Short.parseShort(abArray[k++].attrVal) != 0;
			bo.creator = abArray[k++].attrVal;
			bo.createTime = Integer.valueOf(abArray[k++].attrVal);
			bo.modifier = abArray[k++].attrVal;
			bo.modifyTime = Integer.valueOf(abArray[k++].attrVal);
			bo.revisionRule = abArray[k++].attrVal;
			bo.versionRule = abArray[k++].attrVal;
			bo.revisionSeq = Short.parseShort(abArray[k++].attrVal);
			bo.revisionValue = abArray[k++].attrVal;
			bo.versionSeq = Short.parseShort(abArray[k++].attrVal);
			bo.versionValue = abArray[k++].attrVal;
			bo.lctId = abArray[k++].attrVal;
			bo.lcStatus = abArray[k++].attrVal;
			bo.ts = Integer.valueOf(abArray[k++].attrVal);
			bo.id = abArray[k++].attrVal;
			bo.name = abArray[k++].attrVal;
			bo.description = abArray[k++].attrVal;
			bo.owner = abArray[k++].attrVal;
//			bo.checkinBy = abArray[k++].attrVal;
//			bo.checkinTime = abArray[k++].attrVal;
//			bo.checkoutBy = abArray[k++].attrVal;
//			bo.checkoutTime = abArray[k++].attrVal;
			bo.fromVersion = abArray[k++].attrVal;
			objList.add(bo);
		}
		return objList;
	}

	/**
	 * Map<String, BusinessObject>
	 * key: 
	 * 	最新版本最新版次:nameOId
	 * 	当前版本最新版次：revisonOId
	 * 	其他：	OId
	 * @param clauseList
	 * @param sql
	 * @return
	 */
	public Map<String, BusinessObject> executeSqlForBtmLRLV(List<String> clauseList, String sql){
		Map<String, BusinessObject> bos = new HashMap<String, BusinessObject>();
		Session session = HibernateSessionFactory.getSession();
		SQLQuery sqlquery = session.createSQLQuery(sql);
		//根据查询模板中的查询列clauseList, 设置map
		List<?> list = sqlquery.list();
		for(int i = 0; i < list.size(); i++){
			BusinessObject bo = new BusinessObject();
			AttributeValue[] abArray = null;
			//当list.get(i)中有多个Object时, 类型为Object[]
			//必须先判断Object[] 再判断Object
//			if((list.get(i)) instanceof Object[]){
				Object[] objs = (Object[])list.get(i);
				abArray = new AttributeValue[clauseList.size()];
				for(int k = 0; k < clauseList.size(); k++){
					AttributeValue ab = new AttributeValue();
					//sessin查询出的值
					Object obj_ = objs[k];
					//clauseList中对应的查询列
					String abName = clauseList.get(k);
					ab.attrName = abName;
					ab.attrVal = String.valueOf(obj_ == null ? "" : obj_);
					abArray[k] = ab;
				}
				
			//当list.get(i)中只有一个Object时, 类型为Object
//			}else{
				//sessin查询出的值
//				Object obj_ = list.get(i);
				//clauseList中对应的查询列
//				String abName = clauseList.get(0);
//				abArray = new AttributeValue[1];
//				AttributeValue ab = new AttributeValue();
//				ab.attrName = abName;
//				ab.attrVal = String.valueOf(obj_ == null ? "" : obj_);
//				abArray[0] = ab;
//				
//			}
			
			bo.newAttrValList = new AttributeValue[0];
			bo.hisAttrValList = abArray;
			//为btm的系统属性赋值
			int k = 0;
			bo.oid = abArray[k++].attrVal;
			bo.revisionid = abArray[k++].attrVal;
			bo.nameoid = abArray[k++].attrVal;
			bo.btName = abArray[k++].attrVal;
			bo.isLastR = Short.parseShort(abArray[k++].attrVal) != 0;
			bo.isFirstR = Short.parseShort(abArray[k++].attrVal) != 0;
			bo.isLastV = Short.parseShort(abArray[k++].attrVal) != 0;
			bo.isFirstV = Short.parseShort(abArray[k++].attrVal) != 0;
			bo.creator = abArray[k++].attrVal;
			bo.createTime = Integer.valueOf(abArray[k++].attrVal);
			bo.modifier = abArray[k++].attrVal;
			bo.modifyTime = Integer.valueOf(abArray[k++].attrVal);
			bo.revisionRule = abArray[k++].attrVal;
			bo.versionRule = abArray[k++].attrVal;
			bo.revisionSeq = Short.parseShort(abArray[k++].attrVal);
			bo.revisionValue = abArray[k++].attrVal;
			bo.versionSeq = Short.parseShort(abArray[k++].attrVal);
			bo.versionValue = abArray[k++].attrVal;
			bo.lctId = abArray[k++].attrVal;
			bo.lcStatus = abArray[k++].attrVal;
			bo.ts = Integer.valueOf(abArray[k++].attrVal);
			bo.id = abArray[k++].attrVal;
			bo.name = abArray[k++].attrVal;
			bo.description = abArray[k++].attrVal;
			bo.owner = abArray[k++].attrVal;
//			bo.checkinBy = abArray[k++].attrVal;
//			bo.checkinTime = abArray[k++].attrVal;
//			bo.checkoutBy = abArray[k++].attrVal;
//			bo.checkoutTime = abArray[k++].attrVal;
			bo.fromVersion = abArray[k++].attrVal;
			
			bos.put(bo.nameoid, bo);
			
		}
		return bos;
	}
	
	/**
	 * Map<String, BusinessObject>
	 * key: 
	 * 	最新版本最新版次:nameOId
	 * 	当前版本最新版次：revisonOId
	 * 	其他：	OId
	 * @param clauseList
	 * @param sql
	 * @return
	 */
	public Map<String, BusinessObject> executeSqlForBtmCRLV(List<String> clauseList, String sql){
		Map<String, BusinessObject> bos = new HashMap<String, BusinessObject>();
		Session session = HibernateSessionFactory.getSession();
		SQLQuery sqlquery = session.createSQLQuery(sql);
		//根据查询模板中的查询列clauseList, 设置map
		List<?> list = sqlquery.list();
		for(int i = 0; i < list.size(); i++){
			BusinessObject bo = new BusinessObject();
			AttributeValue[] abArray = null;
			//当list.get(i)中有多个Object时, 类型为Object[]
			//必须先判断Object[] 再判断Object
//			if((list.get(i)) instanceof Object[]){
				Object[] objs = (Object[])list.get(i);
				abArray = new AttributeValue[clauseList.size()];
				for(int k = 0; k < clauseList.size(); k++){
					AttributeValue ab = new AttributeValue();
					//sessin查询出的值
					Object obj_ = objs[k];
					//clauseList中对应的查询列
					String abName = clauseList.get(k);
					ab.attrName = abName;
					ab.attrVal = String.valueOf(obj_ == null ? "" : obj_);
					abArray[k] = ab;
				}
				
			//当list.get(i)中只有一个Object时, 类型为Object
//			}else{
				//sessin查询出的值
//				Object obj_ = list.get(i);
				//clauseList中对应的查询列
//				String abName = clauseList.get(0);
//				abArray = new AttributeValue[1];
//				AttributeValue ab = new AttributeValue();
//				ab.attrName = abName;
//				ab.attrVal = String.valueOf(obj_ == null ? "" : obj_);
//				abArray[0] = ab;
//				
//			}
			
			bo.newAttrValList = new AttributeValue[0];
			bo.hisAttrValList = abArray;
			//为btm的系统属性赋值
			int k = 0;
			bo.oid = abArray[k++].attrVal;
			bo.revisionid = abArray[k++].attrVal;
			bo.nameoid = abArray[k++].attrVal;
			bo.btName = abArray[k++].attrVal;
			bo.isLastR = Short.parseShort(abArray[k++].attrVal) != 0;
			bo.isFirstR = Short.parseShort(abArray[k++].attrVal) != 0;
			bo.isLastV = Short.parseShort(abArray[k++].attrVal) != 0;
			bo.isFirstV = Short.parseShort(abArray[k++].attrVal) != 0;
			bo.creator = abArray[k++].attrVal;
			bo.createTime = Integer.valueOf(abArray[k++].attrVal);
			bo.modifier = abArray[k++].attrVal;
			bo.modifyTime = Integer.valueOf(abArray[k++].attrVal);
			bo.revisionRule = abArray[k++].attrVal;
			bo.versionRule = abArray[k++].attrVal;
			bo.revisionSeq = Short.parseShort(abArray[k++].attrVal);
			bo.revisionValue = abArray[k++].attrVal;
			bo.versionSeq = Short.parseShort(abArray[k++].attrVal);
			bo.versionValue = abArray[k++].attrVal;
			bo.lctId = abArray[k++].attrVal;
			bo.lcStatus = abArray[k++].attrVal;
			bo.ts = Integer.valueOf(abArray[k++].attrVal);
			bo.id = abArray[k++].attrVal;
			bo.name = abArray[k++].attrVal;
			bo.description = abArray[k++].attrVal;
			bo.owner = abArray[k++].attrVal;
//			bo.checkinBy = abArray[k++].attrVal;
//			bo.checkinTime = abArray[k++].attrVal;
//			bo.checkoutBy = abArray[k++].attrVal;
//			bo.checkoutTime = abArray[k++].attrVal;
			bo.fromVersion = abArray[k++].attrVal;
			
			bos.put(bo.revisionid, bo);
		}
		return bos;
	}
	
	/**
	 * 仅仅查询OID, REVISIONOID, NAMEOID
	 * Map<String, BusinessObject>
	 * key: 
	 * 	最新版本最新版次:nameOId
	 * 	当前版本最新版次：revisonOId
	 * 	其他：	OId
	 * @param clauseList
	 * @param sql
	 * @return
	 */
	private Map<String, BusinessObject> executeSqlForBtmOIDS(String sql, int version){
		Map<String, BusinessObject> bos = new HashMap<String, BusinessObject>();
		Session session = HibernateSessionFactory.getSession();
		SQLQuery sqlquery = session.createSQLQuery(sql);
		//根据查询模板中的查询列clauseList, 设置map
		List<?> list = sqlquery.list();
		if(version == Version.currentRevLastVer){
			for(int i = 0; i < list.size(); i++){
				Object[] o = (Object[]) list.get(i);
				BusinessObject bo = new BusinessObject();
				bo.oid = (String) o[0];
				bo.revisionid = (String) o[1];
				bo.nameoid = (String) o[2];
				bos.put(bo.revisionid, bo);
			}
		}else if(version == Version.lastRevLastVer){
			for(int i = 0; i < list.size(); i++){
				Object[] o = (Object[]) list.get(i);
				BusinessObject bo = new BusinessObject();
				bo.oid = (String) o[0];
				bo.revisionid = (String) o[1];
				bo.nameoid = (String) o[2];
				bos.put(bo.nameoid, bo);
			}
		}else{
			for(int i = 0; i < list.size(); i++){
				Object[] o = (Object[]) list.get(i);
				BusinessObject bo = new BusinessObject();
				bo.oid = (String) o[0];
				bo.revisionid = (String) o[1];
				bo.nameoid = (String) o[2];
				bos.put(bo.oid, bo);
			}
		}
		
		return bos;
	}
	
	/**
	 * Map<String, BusinessObject>
	 * key: 
	 * 	最新版本最新版次:nameOId
	 * 	当前版本最新版次：revisonOId
	 * 	其他：	OId
	 * @param clauseList
	 * @param sql
	 * @return
	 */
	public Map<String, BusinessObject> executeSqlForBtmOtherRV(List<String> clauseList, String sql){
		Map<String, BusinessObject> bos = new HashMap<String, BusinessObject>();
		Session session = HibernateSessionFactory.getSession();
		SQLQuery sqlquery = session.createSQLQuery(sql);
		//根据查询模板中的查询列clauseList, 设置map
		List<?> list = sqlquery.list();
		for(int i = 0; i < list.size(); i++){
			BusinessObject bo = new BusinessObject();
			AttributeValue[] abArray = null;
			//当list.get(i)中有多个Object时, 类型为Object[]
			//必须先判断Object[] 再判断Object
//			if((list.get(i)) instanceof Object[]){
				Object[] objs = (Object[])list.get(i);
				abArray = new AttributeValue[clauseList.size()];
				for(int k = 0; k < clauseList.size(); k++){
					AttributeValue ab = new AttributeValue();
					//sessin查询出的值
					Object obj_ = objs[k];
					//clauseList中对应的查询列
					String abName = clauseList.get(k);
					ab.attrName = abName;
					ab.attrVal = String.valueOf(obj_ == null ? "" : obj_);
					abArray[k] = ab;
				}
				
			//当list.get(i)中只有一个Object时, 类型为Object
//			}else{
				//sessin查询出的值
//				Object obj_ = list.get(i);
				//clauseList中对应的查询列
//				String abName = clauseList.get(0);
//				abArray = new AttributeValue[1];
//				AttributeValue ab = new AttributeValue();
//				ab.attrName = abName;
//				ab.attrVal = String.valueOf(obj_ == null ? "" : obj_);
//				abArray[0] = ab;
//				
//			}
			
			bo.newAttrValList = new AttributeValue[0];
			bo.hisAttrValList = abArray;
			//为btm的系统属性赋值
			int k = 0;
			bo.oid = abArray[k++].attrVal;
			bo.revisionid = abArray[k++].attrVal;
			bo.nameoid = abArray[k++].attrVal;
			bo.btName = abArray[k++].attrVal;
			bo.isLastR = Short.parseShort(abArray[k++].attrVal) != 0;
			bo.isFirstR = Short.parseShort(abArray[k++].attrVal) != 0;
			bo.isLastV = Short.parseShort(abArray[k++].attrVal) != 0;
			bo.isFirstV = Short.parseShort(abArray[k++].attrVal) != 0;
			bo.creator = abArray[k++].attrVal;
			bo.createTime = Integer.valueOf(abArray[k++].attrVal);
			bo.modifier = abArray[k++].attrVal;
			bo.modifyTime = Integer.valueOf(abArray[k++].attrVal);
			bo.revisionRule = abArray[k++].attrVal;
			bo.versionRule = abArray[k++].attrVal;
			bo.revisionSeq = Short.parseShort(abArray[k++].attrVal);
			bo.revisionValue = abArray[k++].attrVal;
			bo.versionSeq = Short.parseShort(abArray[k++].attrVal);
			bo.versionValue = abArray[k++].attrVal;
			bo.lctId = abArray[k++].attrVal;
			bo.lcStatus = abArray[k++].attrVal;
			bo.ts = Integer.valueOf(abArray[k++].attrVal);
			bo.id = abArray[k++].attrVal;
			bo.name = abArray[k++].attrVal;
			bo.description = abArray[k++].attrVal;
			bo.owner = abArray[k++].attrVal;
//			bo.checkinBy = abArray[k++].attrVal;
//			bo.checkinTime = abArray[k++].attrVal;
//			bo.checkoutBy = abArray[k++].attrVal;
//			bo.checkoutTime = abArray[k++].attrVal;
			bo.fromVersion = abArray[k++].attrVal;
			
			bos.put(bo.oid, bo);
			
		}
		return bos;
	}
	
	/**
	 * 解析QueryTemplate 为sql
	 * 执行sql, 返回结果
	 * @param queryTemplate
	 * @return
	 * @throws VCIError 
	 */
	public List<LinkObject> findLinkObject(QueryTemplate queryTemplate) throws Throwable{
		List<String> clauseList = queryTemplate.getClauseList();
		String ltName = queryTemplate.getLinkType();
		String ltTableName = OmdHelper.getLTTableName(ltName);
		String btmName = queryTemplate.getBtmType();
		String btmTableName = OmdHelper.getBTTableName(btmName);
		boolean btmFlag = false;
//		if (clauseList.contains(ltTableName + ".*") || clauseList.contains("*")) {
			clauseList = getAllLinkTypeFiledsWithTableName(ltName, ltTableName);
			if(btmName != null && !btmName.equals("")){
				btmFlag = true;
				clauseList.add(btmTableName + ".OID AS OID2");
				clauseList.add(btmTableName + ".REVISIONOID AS REVISIONOID2");
			}
			clauseList.add("CONNECT_BY_ISLEAF");
			clauseList.add("LEVEL");
//		}
		queryTemplate.setClauseList(clauseList);
		Parser parser = new Parser(queryTemplate);
		String sql = parser.parseToSql();
		List<LinkObject> objList = null;
		if(btmFlag){
			objList = executeSqlForLink(clauseList, sql, queryTemplate.getDirection(), ltName);
		}else{
			objList = executeSqlForLinkOnly(clauseList, sql, ltName);
		}
		return objList;
	}
	
	/**
	 * 查询链接类型
	 * 通过连接业务类型表, 替换btmOId, btmRevisionOId
	 * @param clauseList
	 * @param sql
	 * @param queryType
	 * @param direction
	 * @return
	 * @throws VCIError
	 */
	public List<LinkObject> executeSqlForLink(List<String> clauseList, String sql, String direction, String ltName) throws VCIError{
		try{
			Session session = HibernateSessionFactory.getSession();
			List<LinkObject> objList = new ArrayList<LinkObject>();
			SQLQuery sqlquery = session.createSQLQuery(sql);
			//根据查询模板中的查询列clauseList, 设置map
			
			List<?> list = sqlquery.list();
			for(int i = 0; i < list.size(); i++){
				
				LinkObject lo = new LinkObject();
				AttributeValue[] abArray = null;
				//当list.get(i)中有多个Object时, 类型为Object[]
				//必须先判断Object[] 在判断Object
//				if(list.get(i) instanceof Object[]){
					Object[] objs = (Object[])list.get(i);
					abArray = new AttributeValue[clauseList.size()];
					for(int k = 0; k < clauseList.size(); k++){
						AttributeValue ab = new AttributeValue();
						//sessin查询出的值
						Object value = objs[k];
						//clauseList中对应的查询列
						String abName = clauseList.get(k);
						if(abName.contains(".")){
							abName = abName.substring(abName.indexOf(".") + 1);
						//abName: CONNECT_BY_ISLEAF --> _ISLEAF
						}else if(abName.equals("CONNECT_BY_ISLEAF")){
							abName = "_ISLEAF";
						}else if(abName.equals("LEVEL")){
							abName = "_LEVEL";
						}
						//只查询链接时, 没有direction
						if(direction != null){
							if(direction.equalsIgnoreCase(QTConstants.DIRECTION_POSITIVE)){
								//正向查询(反向查询不用覆盖)
								//查询出的to端的btm对象的OID和REVISIONOID, 
								//覆盖link对象中的t_OId 和 t_RevisionOId
								if(abName.toUpperCase().equals("OID AS OID2") && k > 0){
									abName = "t_OId";
								}
								if(abName.toUpperCase().equals("REVISIONOID AS REVISIONOID2") && k > 0){
									abName = "t_RevisionOId";
								}
							}
						}
						ab.attrName = abName;
						ab.attrVal = String.valueOf(value == null ? "" : value);
						abArray[k] = ab;
					}
				//当list.get(i)中只有一个Object时, 类型为Object
//				}else{
					//sessin查询出的值
//					Object obj = list.get(i);
					//clauseList中对应的查询列
//					String abName = clauseList.get(0);
//					if(abName.contains(".")){
//						abName = abName.substring(abName.indexOf(".") + 1);
//					}
					//只查询链接时, 没有direction
//					if(direction != null){
//						if(direction.equalsIgnoreCase(QTConstants.DIRECTION_POSITIVE)){
							//正向查询(反向查询不用覆盖)
							//查询出的to端的btm对象的OID和REVISIONOID, 
							//覆盖link对象中的t_OId 和 t_RevisionOId
//							if(abName.toUpperCase().equals("OID AS OID2")){
//								abName = "t_OId";
//							}
//							if(abName.toUpperCase().equals("REVISIONOID AS REVISIONOID2")){
//								abName = "t_RevisionOId";
//							}
//						}
//					}
//					abArray = new AttributeValue[1];
//					AttributeValue ab = new AttributeValue();
//					ab.attrName = abName;
//					ab.attrVal = String.valueOf(obj == null ? "" : obj);
//					abArray[0] = ab;
//				}
				//为link的系统属性赋值
				int k = 0;
				lo.oid = abArray[k++].attrVal;
				lo.creator = abArray[k++].attrVal;
				lo.createTime = Integer.valueOf(abArray[k++].attrVal);
				lo.modifier = abArray[k++].attrVal;
				lo.modifyTime = Integer.valueOf(abArray[k++].attrVal);
				lo.fromOid = abArray[k++].attrVal;
				lo.fromRevOid = abArray[k++].attrVal;
				lo.fromNameOid = abArray[k++].attrVal;
				lo.fromBTName = abArray[k++].attrVal;
				lo.toOid = abArray[k++].attrVal;
				lo.toRevOid = abArray[k++].attrVal;
				lo.toNameOid = abArray[k++].attrVal;
				lo.toBTName = abArray[k++].attrVal;
				lo.ts = Integer.valueOf(abArray[k++].attrVal);
				if(direction != null){
					if(direction.equalsIgnoreCase(QTConstants.DIRECTION_OPPOSITE)){
						//反向查询
						//查询出的from端的btm对象的OID和REVISIONOID, 
						//覆盖link对象中的f_OId 和 f_RevisionOId
						int flag = 0;
						for(int m = abArray.length - 2; m > k; m--){
							AttributeValue ab = abArray[m];
							if(ab.attrName.equalsIgnoreCase("F_REVISIONOID")){
								lo.fromRevOid = abArray[m].attrVal;
								flag++;
							}
							if(ab.attrName.equalsIgnoreCase("F_OID")){
								lo.fromOid = abArray[m].attrVal;
								flag++;
							}
							
							if(flag == 2){
								break;
							}
						}
						
					}else if(direction.equalsIgnoreCase(QTConstants.DIRECTION_POSITIVE)){
						//正向查询
						//查询出的to端的btm对象的OID和REVISIONOID, 
						//覆盖link对象中的t_OId 和 t_RevisionOId
						int flag = 0;
						for(int m = abArray.length - 2; m > k; m--){
							AttributeValue ab = abArray[m];
							if(ab.attrName.equalsIgnoreCase("T_REVISIONOID")){
								lo.toRevOid = abArray[m].attrVal;
								flag++;
							}
							if(ab.attrName.equalsIgnoreCase("T_OID")){
								lo.toOid = abArray[m].attrVal;
								flag++;
							}
							
							if(flag == 2){
								break;
							}
						}
					}
				}
				lo.hisAttrValList = abArray;
				lo.newAttrValList = new AttributeValue[0];
				//目前系统属性没有ltName, 传参赋值
				lo.ltName = ltName;
				objList.add(lo);
			}
			return objList;
		}catch(Throwable e){
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00009", e);
		}
		
	}
	
	/**
	 * 查询链接类型
	 * 只查询链接类型, 不需要替换btmOId, btmRevisionOId
	 * @param clauseList
	 * @param sql
	 * @param queryType
	 * @param direction
	 * @param ltName : 目前系统属性没有ltName
	 * @return
	 * @throws VCIError
	 */
	public List<LinkObject> executeSqlForLinkOnly(List<String> clauseList, String sql, String ltName) throws VCIError{
		try{
			Session session = HibernateSessionFactory.getSession();
			List<LinkObject> objList = new ArrayList<LinkObject>();
			SQLQuery sqlquery = session.createSQLQuery(sql);
			//根据查询模板中的查询列clauseList, 设置map
			
			List<?> list = sqlquery.list();
			for(int i = 0; i < list.size(); i++){
				
				LinkObject lo = new LinkObject();
				AttributeValue[] abArray = null;
				//当list.get(i)中有多个Object时, 类型为Object[]
				//必须先判断Object[] 在判断Object
//				if(list.get(i) instanceof Object[]){
					Object[] objs = (Object[])list.get(i);
					abArray = new AttributeValue[clauseList.size()];
					for(int k = 0; k < clauseList.size(); k++){
						AttributeValue ab = new AttributeValue();
						//sessin查询出的值
						Object value = objs[k];
						//clauseList中对应的查询列
						String abName = clauseList.get(k);
						if(abName.contains(".")){
							abName = abName.substring(abName.indexOf(".") + 1);
						//abName: CONNECT_BY_ISLEAF --> _ISLEAF
						}else if(abName.equals("CONNECT_BY_ISLEAF")){
							abName = "_ISLEAF";
						}else if(abName.equals("LEVEL")){
							abName = "_LEVEL";
						}
						
						ab.attrName = abName;
						ab.attrVal = String.valueOf(value == null ? "" : value);
						abArray[k] = ab;
					}
				//当list.get(i)中只有一个Object时, 类型为Object
//				}else{
					//sessin查询出的值
//					Object obj = list.get(i);
					//clauseList中对应的查询列
//					String abName = clauseList.get(0);
//					if(abName.contains(".")){
//						abName = abName.substring(abName.indexOf(".") + 1);
//					}
//					abArray = new AttributeValue[1];
//					AttributeValue ab = new AttributeValue();
//					ab.attrName = abName;
//					ab.attrVal = String.valueOf(obj == null ? "" : obj);
//					abArray[0] = ab;
//				}
				//为link的系统属性赋值
				int k = 0;
				lo.oid = abArray[k++].attrVal;
				lo.creator = abArray[k++].attrVal;
				lo.createTime = Integer.valueOf(abArray[k++].attrVal);
				lo.modifier = abArray[k++].attrVal;
				lo.modifyTime = Integer.valueOf(abArray[k++].attrVal);
				lo.fromOid = abArray[k++].attrVal;
				lo.fromRevOid = abArray[k++].attrVal;
				lo.fromNameOid = abArray[k++].attrVal;
				lo.fromBTName = abArray[k++].attrVal;
				lo.toOid = abArray[k++].attrVal;
				lo.toRevOid = abArray[k++].attrVal;
				lo.toNameOid = abArray[k++].attrVal;
				lo.toBTName = abArray[k++].attrVal;
				lo.ts = Integer.valueOf(abArray[k++].attrVal);
				lo.hisAttrValList = abArray;
				lo.newAttrValList = new AttributeValue[0];
				//目前系统属性没有ltName, 传参赋值
				lo.ltName = ltName;
				objList.add(lo);
			}
			return objList;
		}catch(Throwable e){
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00009", e);
		}
		
	}
	
	/**
	 * 查询链接类型
	 * 用Map替换btmOId, btmRevisionOId
	 * 只有正向查询的Version.currentRevLastVer, Version.lastRevLastVer情况下调到
	 * @param clauseList
	 * @param sql
	 * @param queryType
	 * @return
	 * @throws VCIError
	 */
	public List<LinkObject> executeSqlForLinkLRLV(List<String> clauseList, String sql, Map<String, BusinessObject> bos, String ltName) throws VCIError{
		try{
			Session session = HibernateSessionFactory.getSession();
			List<LinkObject> objList = new ArrayList<LinkObject>();
			SQLQuery sqlquery = session.createSQLQuery(sql);
			//根据查询模板中的查询列clauseList, 设置map
			
			List<?> list = sqlquery.list();
			for(int i = 0; i < list.size(); i++){
				
				LinkObject lo = new LinkObject();
				AttributeValue[] abArray = null;
				//当list.get(i)中有多个Object时, 类型为Object[]
				//必须先判断Object[] 在判断Object
//				if(list.get(i) instanceof Object[]){
					Object[] objs = (Object[])list.get(i);
					abArray = new AttributeValue[clauseList.size()];
					for(int k = 0; k < clauseList.size(); k++){
						AttributeValue ab = new AttributeValue();
						//sessin查询出的值
						Object value = objs[k];
						//clauseList中对应的查询列
						String abName = clauseList.get(k);
						if(abName.contains(".")){
							abName = abName.substring(abName.indexOf(".") + 1);
						//abName: CONNECT_BY_ISLEAF --> _ISLEAF
						}else if(abName.equals("CONNECT_BY_ISLEAF")){
							abName = "_ISLEAF";
						}else if(abName.equals("LEVEL")){
							abName = "_LEVEL";
						}
						
						ab.attrName = abName;
						ab.attrVal = String.valueOf(value == null ? "" : value);
						abArray[k] = ab;
					}
				//当list.get(i)中只有一个Object时, 类型为Object
//				}else{
					//sessin查询出的值
//					Object obj = list.get(i);
					//clauseList中对应的查询列
//					String abName = clauseList.get(0);
//					if(abName.contains(".")){
//						abName = abName.substring(abName.indexOf(".") + 1);
//					}
//					abArray = new AttributeValue[1];
//					AttributeValue ab = new AttributeValue();
//					ab.attrName = abName;
//					ab.attrVal = String.valueOf(obj == null ? "" : obj);
//					abArray[0] = ab;
//				}
				//为link的系统属性赋值
				int k = 0;
				lo.oid = abArray[k++].attrVal;
				lo.creator = abArray[k++].attrVal;
				lo.createTime = Integer.valueOf(abArray[k++].attrVal);
				lo.modifier = abArray[k++].attrVal;
				lo.modifyTime = Integer.valueOf(abArray[k++].attrVal);
				lo.fromOid = abArray[k++].attrVal;
				lo.fromRevOid = abArray[k++].attrVal;
				lo.fromNameOid = abArray[k++].attrVal;
				lo.fromBTName = abArray[k++].attrVal;
				lo.toOid = abArray[k++].attrVal;
				lo.toRevOid = abArray[k++].attrVal;
				lo.toNameOid = abArray[k++].attrVal;
				lo.toBTName = abArray[k++].attrVal;
				lo.ts = Integer.valueOf(abArray[k++].attrVal);
				lo.hisAttrValList = abArray;
				lo.newAttrValList = new AttributeValue[0];
				
				//目前系统属性没有ltName, 传参赋值
				lo.ltName = ltName;
				
				//lastRevLastVer
				BusinessObject bo = bos.get(lo.toNameOid);
				if(bo != null){
					lo.toOid = bo.oid;
					lo.toRevOid = bo.revisionid;
					objList.add(lo);
				}
			}
			return objList;
		}catch(Throwable e){
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00009", e);
		}
		
	}
	
	/**
	 * 查询链接类型
	 * 用Map替换btmOId, btmRevisionOId
	 * 只有正向查询的Version.currentRevLastVer, Version.lastRevLastVer情况下调到
	 * @param clauseList
	 * @param sql
	 * @param queryType
	 * @return
	 * @throws VCIError
	 */
	public List<LinkObject> executeSqlForLinkCRLV(List<String> clauseList, String sql, Map<String, BusinessObject> bos, String ltName) throws VCIError{
		try{
			Session session = HibernateSessionFactory.getSession();
			List<LinkObject> objList = new ArrayList<LinkObject>();
			SQLQuery sqlquery = session.createSQLQuery(sql);
			//根据查询模板中的查询列clauseList, 设置map
			
			List<?> list = sqlquery.list();
			for(int i = 0; i < list.size(); i++){
				
				LinkObject lo = new LinkObject();
				AttributeValue[] abArray = null;
				//当list.get(i)中有多个Object时, 类型为Object[]
				//必须先判断Object[] 在判断Object
//				if(list.get(i) instanceof Object[]){
					Object[] objs = (Object[])list.get(i);
					abArray = new AttributeValue[clauseList.size()];
					for(int k = 0; k < clauseList.size(); k++){
						AttributeValue ab = new AttributeValue();
						//sessin查询出的值
						Object value = objs[k];
						//clauseList中对应的查询列
						String abName = clauseList.get(k);
						if(abName.contains(".")){
							abName = abName.substring(abName.indexOf(".") + 1);
						//abName: CONNECT_BY_ISLEAF --> _ISLEAF
						}else if(abName.equals("CONNECT_BY_ISLEAF")){
							abName = "_ISLEAF";
						}else if(abName.equals("LEVEL")){
							abName = "_LEVEL";
						}
						
						ab.attrName = abName;
						ab.attrVal = String.valueOf(value == null ? "" : value);
						abArray[k] = ab;
					}
				//当list.get(i)中只有一个Object时, 类型为Object
//				}else{
					//sessin查询出的值
//					Object obj = list.get(i);
					//clauseList中对应的查询列
//					String abName = clauseList.get(0);
//					if(abName.contains(".")){
//						abName = abName.substring(abName.indexOf(".") + 1);
//					}
//					abArray = new AttributeValue[1];
//					AttributeValue ab = new AttributeValue();
//					ab.attrName = abName;
//					ab.attrVal = String.valueOf(obj == null ? "" : obj);
//					abArray[0] = ab;
//				}
				//为link的系统属性赋值
				int k = 0;
				lo.oid = abArray[k++].attrVal;
				lo.creator = abArray[k++].attrVal;
				lo.createTime = Integer.valueOf(abArray[k++].attrVal);
				lo.modifier = abArray[k++].attrVal;
				lo.modifyTime = Integer.valueOf(abArray[k++].attrVal);
				lo.fromOid = abArray[k++].attrVal;
				lo.fromRevOid = abArray[k++].attrVal;
				lo.fromNameOid = abArray[k++].attrVal;
				lo.fromBTName = abArray[k++].attrVal;
				lo.toOid = abArray[k++].attrVal;
				lo.toRevOid = abArray[k++].attrVal;
				lo.toNameOid = abArray[k++].attrVal;
				lo.toBTName = abArray[k++].attrVal;
				lo.ts = Integer.valueOf(abArray[k++].attrVal);
				lo.hisAttrValList = abArray;
				lo.newAttrValList = new AttributeValue[0];
				//目前系统属性没有ltName, 传参赋值
				lo.ltName = ltName;
				
				//currentRevLastVer
				BusinessObject bo = bos.get(lo.toRevOid);
				if(bo != null){
					lo.toOid = bo.oid;
					objList.add(lo);
				}
			}
			return objList;
		}catch(Throwable e){
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00009", e);
		}
		
	}
	
	/**
	 * 获取业务类型全部属性, 包括系统属性和属性池属性
	 * @param btmName
	 * @return
	 * @throws Throwable 
	 */
	private List<String> getAllAbNamesForBtm(String btmName) throws Throwable{
		try{
			List<String> abList = new ArrayList<String>();
			String[] sysAbs = BusinessConstants.SELECT_CONSTANTS;
			for(int i = 0; i < sysAbs.length; i++){
				abList.add(sysAbs[i]);
			}
			//String[] abs = ServerServiceProvider.getOMDService().getBTMService().getBtmApNameArray(btmName);
			String[] abs = OMCacheProvider.getBTAttributes(btmName);
			for(int i = 0; i < abs.length; i++){
				abList.add(abs[i]);
			}
			return abList;
		}catch(Throwable e){
			e.printStackTrace();
			throw e;
		}
	}
	
	/**
	 * 获取链接类型全部属性, 包括系统属性和属性池属性
	 * @param ltName
	 * @return
	 * @throws Throwable 
	 */
	private List<String> getAllAbNamesForLink(String ltName) throws Throwable{
		try{
			List<String> abList = new ArrayList<String>();
			String[] sysAbs = LinkConstants.SELECT_CONSTANTS;
			for(int i = 0; i < sysAbs.length; i++){
				abList.add(sysAbs[i]);
			}
			//LinkType linkType = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(ltName);
			LinkType linkType = OMCacheProvider.getLinkType(ltName);
			String[] abs = linkType.attributes;
			for(int i = 0; i < abs.length; i++){
				abList.add(abs[i]);
			}
			return abList;
		}catch(Throwable e){
			e.printStackTrace();
			throw e;
		}
	}
	
	/**
	 * 根据查询模板获取linkObject 和 关联的businessObject
	 * @param qt
	 * @return
	 * @throws Throwable 
	 */
	public List<BOAndLO> findBOAndLOList(QueryTemplate qt) throws Throwable {
		try{
			List<BOAndLO> blList = new ArrayList<BOAndLO>();
			List<String> clauseList = qt.getClauseList();
			String ltName = qt.getLinkType();
			String ltTableName = OmdHelper.getLTTableName(ltName);
			String btmName = qt.getBtmType();
//			if (clauseList.contains(ltTableName + ".*") || clauseList.contains("*")) {
				clauseList = getAllLinkTypeFiledsWithTableName(ltName, ltTableName);
				clauseList.add("CONNECT_BY_ISLEAF");
				clauseList.add("LEVEL");
				clauseList.addAll(getAllBtmFiledsWithAlias(btmName));
//			}
			qt.setClauseList(clauseList);
			//查询结果
			Parser p = new Parser(qt);
			String sql = p.parseToSql();
			Session session = HibernateSessionFactory.getSession();
			List<?> list = session.createSQLQuery(sql).list();
			
			//获取link和btm的全部属性
			List<String> ltAbNames = getAllAbNamesForLink(ltName);
			List<String> btmAbNames = getAllAbNamesForBtm(btmName);
			
			//封装BOANDLO对象
			for(int i = 0; i < list.size(); i++){
				BOAndLO bl = new BOAndLO();
				bl.btmName = btmName;
				bl.ltName = ltName;
				Object o = list.get(i);
//				if(o instanceof Object[]){
					Object[] obj = (Object[])o;
					//取值封装LinkObject
					LinkObject lo = new LinkObject();
					AttributeValue[] ltAbArray = new AttributeValue[ltAbNames.size() + 2];
					for(int k = 0; k < ltAbNames.size(); k++){
						AttributeValue ab = new AttributeValue();
						ab.attrName = ltAbNames.get(k);
						Object value = obj[k];
						ab.attrVal = String.valueOf(value == null ? "" : value);
						ltAbArray[k] = ab;
					}
					
					//_ISLEAF属性赋值
					AttributeValue isleafAb = new AttributeValue();
					isleafAb.attrName = "_ISLEAF";
					Object isleafVal = obj[ltAbNames.size()];
					isleafAb.attrVal = String.valueOf(isleafVal == null ? "" : isleafVal);
					ltAbArray[ltAbNames.size()] = isleafAb;
					//_LEVEL属性赋值
					AttributeValue levelAb = new AttributeValue();
					levelAb.attrName = "_LEVEL";
					Object levelVal = obj[ltAbNames.size() + 1];
					levelAb.attrVal = String.valueOf(levelVal == null ? "" : levelVal);
					ltAbArray[ltAbNames.size() + 1] = levelAb;
					
					//为link的系统属性赋值
					int k_ = 0;
					lo.oid = ltAbArray[k_++].attrVal;
					lo.creator = ltAbArray[k_++].attrVal;
					lo.createTime = Integer.valueOf(ltAbArray[k_++].attrVal);
					lo.modifier = ltAbArray[k_++].attrVal;
					lo.modifyTime = Integer.valueOf(ltAbArray[k_++].attrVal);
					lo.fromOid = ltAbArray[k_++].attrVal;
					lo.fromRevOid = ltAbArray[k_++].attrVal;
					lo.fromNameOid = ltAbArray[k_++].attrVal;
					lo.fromBTName = ltAbArray[k_++].attrVal;
					lo.toOid = ltAbArray[k_++].attrVal;
					lo.toRevOid = ltAbArray[k_++].attrVal;
					lo.toNameOid = ltAbArray[k_++].attrVal;
					lo.toBTName = ltAbArray[k_++].attrVal;
					lo.ts = Integer.valueOf(ltAbArray[k_++].attrVal);
					
					lo.hisAttrValList = ltAbArray;
					lo.newAttrValList = new AttributeValue[0];
					
					//目前系统属性没有ltName, 传参赋值
					lo.ltName = ltName;
					
					bl.lo = lo;
					//取值封装btmObject
					BusinessObject bo = new BusinessObject();
					AttributeValue[] btmAbArray = new AttributeValue[btmAbNames.size()];
					int ltAblength = ltAbNames.size();
					for(int k = 0; k < btmAbNames.size(); k++){
						AttributeValue ab = new AttributeValue();
						ab.attrName = btmAbNames.get(k);
						//+2为CONNECT_BY_ISLEAF, LEVEL
						Object value = obj[k + ltAblength + 2];
						ab.attrVal = String.valueOf(value == null ? "" : value);
						btmAbArray[k] = ab;
					}
					//为Btm的系统属性赋值
					bo.hisAttrValList = btmAbArray;
					bo.newAttrValList = new AttributeValue[0];
					int k = 0;
					bo.oid = btmAbArray[k++].attrVal;
					bo.revisionid = btmAbArray[k++].attrVal;
					bo.nameoid = btmAbArray[k++].attrVal;
					bo.btName = btmAbArray[k++].attrVal;
					bo.modifyTime = Integer.valueOf(btmAbArray[k++].attrVal);
					bo.isFirstR = Short.parseShort(btmAbArray[k++].attrVal) != 0;
					bo.isLastV = Short.parseShort(btmAbArray[k++].attrVal) != 0;
					bo.isFirstV = Short.parseShort(btmAbArray[k++].attrVal) != 0;
					bo.creator = btmAbArray[k++].attrVal;
					bo.createTime = Integer.valueOf(btmAbArray[k++].attrVal);
					bo.modifier = btmAbArray[k++].attrVal;
					bo.modifyTime = Integer.valueOf(btmAbArray[k++].attrVal);
					bo.revisionRule = btmAbArray[k++].attrVal;
					bo.versionRule = btmAbArray[k++].attrVal;
					bo.revisionSeq = Short.parseShort(btmAbArray[k++].attrVal);
					bo.revisionValue = btmAbArray[k++].attrVal;
					bo.versionSeq = Short.parseShort(btmAbArray[k++].attrVal);
					bo.versionValue = btmAbArray[k++].attrVal;
					bo.lctId = btmAbArray[k++].attrVal;
					bo.lcStatus = btmAbArray[k++].attrVal;
					bo.ts = Integer.valueOf(btmAbArray[k++].attrVal);
					bo.id = btmAbArray[k++].attrVal;
					bo.name = btmAbArray[k++].attrVal;
					bo.description = btmAbArray[k++].attrVal;
					bo.owner = btmAbArray[k++].attrVal;
//					bo.checkinBy = btmAbArray[k++].attrVal;
//					bo.checkinTime = btmAbArray[k++].attrVal;
//					bo.checkoutBy = btmAbArray[k++].attrVal;
//					bo.checkoutTime = btmAbArray[k++].attrVal;
					bo.fromVersion = btmAbArray[k++].attrVal;
					bl.bo = bo;
//				}else{
					//因为全部查询，不是单独列的查询
//				}
				
				blList.add(bl);
			}
			return blList;
		}catch(Throwable e){
			e.printStackTrace();
			throw e;
		}
		
	}
	
	/**
	 * 查询出链接对象, 根据版本版次条件拼接上业务对象
	 * @param clauseList
	 * @param sql
	 * @param queryType
	 * @return
	 * @throws VCIError
	 */
	public List<BOAndLO> findBOAndLOListLRLV(List<String> clauseList, String sql, Map<String, BusinessObject> bos) throws VCIError{
		try{
			Session session = HibernateSessionFactory.getSession();
			List<BOAndLO> objList = new ArrayList<BOAndLO>();
			SQLQuery sqlquery = session.createSQLQuery(sql);
			//根据查询模板中的查询列clauseList, 设置map
			
			List<?> list = sqlquery.list();
			for(int i = 0; i < list.size(); i++){
				
				LinkObject lo = new LinkObject();
				AttributeValue[] abArray = null;
				//当list.get(i)中有多个Object时, 类型为Object[]
				//必须先判断Object[] 在判断Object
//				if(list.get(i) instanceof Object[]){
					Object[] objs = (Object[])list.get(i);
					abArray = new AttributeValue[clauseList.size()];
					for(int k = 0; k < clauseList.size(); k++){
						AttributeValue ab = new AttributeValue();
						//sessin查询出的值
						Object value = objs[k];
						//clauseList中对应的查询列
						String abName = clauseList.get(k);
						if(abName.contains(".")){
							abName = abName.substring(abName.indexOf(".") + 1);
						//abName: CONNECT_BY_ISLEAF --> _ISLEAF
						}else if(abName.equals("CONNECT_BY_ISLEAF")){
							abName = "_ISLEAF";
						}else if(abName.equals("LEVEL")){
							abName = "_LEVEL";
						}
						
						ab.attrName = abName;
						ab.attrVal = String.valueOf(value == null ? "" : value);
						abArray[k] = ab;
					}
				//当list.get(i)中只有一个Object时, 类型为Object
//				}else{
					//sessin查询出的值
//					Object obj = list.get(i);
					//clauseList中对应的查询列
//					String abName = clauseList.get(0);
//					if(abName.contains(".")){
//						abName = abName.substring(abName.indexOf(".") + 1);
//					}
//					abArray = new AttributeValue[1];
//					AttributeValue ab = new AttributeValue();
//					ab.attrName = abName;
//					ab.attrVal = String.valueOf(obj == null ? "" : obj);
//					abArray[0] = ab;
//				}
				//为link的系统属性赋值
				int k = 0;
				lo.oid = abArray[k++].attrVal;
				lo.creator = abArray[k++].attrVal;
				lo.createTime = Integer.valueOf(abArray[k++].attrVal);
				lo.modifier = abArray[k++].attrVal;
				lo.modifyTime = Integer.valueOf(abArray[k++].attrVal);
				lo.fromOid = abArray[k++].attrVal;
				lo.fromRevOid = abArray[k++].attrVal;
				lo.fromNameOid = abArray[k++].attrVal;
				lo.fromBTName = abArray[k++].attrVal;
				lo.toOid = abArray[k++].attrVal;
				lo.toRevOid = abArray[k++].attrVal;
				lo.toNameOid = abArray[k++].attrVal;
				lo.toBTName = abArray[k++].attrVal;
				lo.ts = Integer.valueOf(abArray[k++].attrVal);
				lo.hisAttrValList = abArray;
				lo.newAttrValList = new AttributeValue[0];
				
				BusinessObject bo = bos.get(lo.toNameOid);
				if (bo != null) {
					BOAndLO obj = new BOAndLO();
					obj.bo = bo;
					obj.btmName = bo.btName;
					obj.lo = lo;
					obj.ltName = lo.ltName;
					objList.add(obj);
				}
			}
			return objList;
		}catch(Throwable e){
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00009", e);
		}
		
	}
	
	/**
	 * 查询出链接对象, 根据版本版次条件拼接上业务对象
	 * @param clauseList
	 * @param sql
	 * @param queryType
	 * @return
	 * @throws VCIError
	 */
	public List<BOAndLO> findBOAndLOListCRLV(List<String> clauseList, String sql, Map<String, BusinessObject> bos) throws VCIError{
		try{
			Session session = HibernateSessionFactory.getSession();
			List<BOAndLO> objList = new ArrayList<BOAndLO>();
			SQLQuery sqlquery = session.createSQLQuery(sql);
			//根据查询模板中的查询列clauseList, 设置map
			
			List<?> list = sqlquery.list();
			for(int i = 0; i < list.size(); i++){
				
				LinkObject lo = new LinkObject();
				AttributeValue[] abArray = null;
				//当list.get(i)中有多个Object时, 类型为Object[]
				//必须先判断Object[] 在判断Object
//				if(list.get(i) instanceof Object[]){
					Object[] objs = (Object[])list.get(i);
					abArray = new AttributeValue[clauseList.size()];
					for(int k = 0; k < clauseList.size(); k++){
						AttributeValue ab = new AttributeValue();
						//sessin查询出的值
						Object value = objs[k];
						//clauseList中对应的查询列
						String abName = clauseList.get(k);
						if(abName.contains(".")){
							abName = abName.substring(abName.indexOf(".") + 1);
						//abName: CONNECT_BY_ISLEAF --> _ISLEAF
						}else if(abName.equals("CONNECT_BY_ISLEAF")){
							abName = "_ISLEAF";
						}else if(abName.equals("LEVEL")){
							abName = "_LEVEL";
						}
						
						ab.attrName = abName;
						ab.attrVal = String.valueOf(value == null ? "" : value);
						abArray[k] = ab;
					}
				//当list.get(i)中只有一个Object时, 类型为Object
//				}else{
					//sessin查询出的值
//					Object obj = list.get(i);
					//clauseList中对应的查询列
//					String abName = clauseList.get(0);
//					if(abName.contains(".")){
//						abName = abName.substring(abName.indexOf(".") + 1);
//					}
//					abArray = new AttributeValue[1];
//					AttributeValue ab = new AttributeValue();
//					ab.attrName = abName;
//					ab.attrVal = String.valueOf(obj == null ? "" : obj);
//					abArray[0] = ab;
//				}
				//为link的系统属性赋值
				int k = 0;
				lo.oid = abArray[k++].attrVal;
				lo.creator = abArray[k++].attrVal;
				lo.createTime = Integer.valueOf(abArray[k++].attrVal);
				lo.modifier = abArray[k++].attrVal;
				lo.modifyTime = Integer.valueOf(abArray[k++].attrVal);
				lo.fromOid = abArray[k++].attrVal;
				lo.fromRevOid = abArray[k++].attrVal;
				lo.fromNameOid = abArray[k++].attrVal;
				lo.fromBTName = abArray[k++].attrVal;
				lo.toOid = abArray[k++].attrVal;
				lo.toRevOid = abArray[k++].attrVal;
				lo.toNameOid = abArray[k++].attrVal;
				lo.toBTName = abArray[k++].attrVal;
				lo.ts = Integer.valueOf(abArray[k++].attrVal);
				lo.hisAttrValList = abArray;
				lo.newAttrValList = new AttributeValue[0];
				
				//currentRevLastVer
				BusinessObject bo = bos.get(lo.toRevOid);
				if (bo != null) {
					BOAndLO obj = new BOAndLO();
					obj.bo = bo;
					obj.btmName = bo.btName;
					obj.lo = lo;
					obj.ltName = lo.ltName;
					objList.add(obj);
				}
			}
			return objList;
		}catch(Throwable e){
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00009", e);
		}
		
	}
	
	/**
	 * 查询出链接对象, 根据版本版次条件拼接上业务对象
	 * @param clauseList
	 * @param sql
	 * @param queryType
	 * @return
	 * @throws VCIError
	 */
	public List<BOAndLO> findBOAndLOListOpposite(List<String> clauseList, String sql, Map<String, BusinessObject> bos) throws VCIError{
		try{
			Session session = HibernateSessionFactory.getSession();
			List<BOAndLO> objList = new ArrayList<BOAndLO>();
			SQLQuery sqlquery = session.createSQLQuery(sql);
			//根据查询模板中的查询列clauseList, 设置map
			
			List<?> list = sqlquery.list();
			for(int i = 0; i < list.size(); i++){
				
				LinkObject lo = new LinkObject();
				AttributeValue[] abArray = null;
				//当list.get(i)中有多个Object时, 类型为Object[]
				//必须先判断Object[] 在判断Object
//				if(list.get(i) instanceof Object[]){
					Object[] objs = (Object[])list.get(i);
					abArray = new AttributeValue[clauseList.size()];
					for(int k = 0; k < clauseList.size(); k++){
						AttributeValue ab = new AttributeValue();
						//sessin查询出的值
						Object value = objs[k];
						//clauseList中对应的查询列
						String abName = clauseList.get(k);
						if(abName.contains(".")){
							abName = abName.substring(abName.indexOf(".") + 1);
						//abName: CONNECT_BY_ISLEAF --> _ISLEAF
						}else if(abName.equals("CONNECT_BY_ISLEAF")){
							abName = "_ISLEAF";
						}else if(abName.equals("LEVEL")){
							abName = "_LEVEL";
						}
						
						ab.attrName = abName;
						ab.attrVal = String.valueOf(value == null ? "" : value);
						abArray[k] = ab;
					}
				//当list.get(i)中只有一个Object时, 类型为Object
//				}else{
					//sessin查询出的值
//					Object obj = list.get(i);
					//clauseList中对应的查询列
//					String abName = clauseList.get(0);
//					if(abName.contains(".")){
//						abName = abName.substring(abName.indexOf(".") + 1);
//					}
//					abArray = new AttributeValue[1];
//					AttributeValue ab = new AttributeValue();
//					ab.attrName = abName;
//					ab.attrVal = String.valueOf(obj == null ? "" : obj);
//					abArray[0] = ab;
//				}
				//为link的系统属性赋值
				int k = 0;
				lo.oid = abArray[k++].attrVal;
				lo.creator = abArray[k++].attrVal;
				lo.createTime = Integer.valueOf(abArray[k++].attrVal);
				lo.modifier = abArray[k++].attrVal;
				lo.modifyTime = Integer.valueOf(abArray[k++].attrVal);
				lo.fromOid = abArray[k++].attrVal;
				lo.fromRevOid = abArray[k++].attrVal;
				lo.fromNameOid = abArray[k++].attrVal;
				lo.fromBTName = abArray[k++].attrVal;
				lo.toOid = abArray[k++].attrVal;
				lo.toRevOid = abArray[k++].attrVal;
				lo.toNameOid = abArray[k++].attrVal;
				lo.toBTName = abArray[k++].attrVal;
				lo.ts = Integer.valueOf(abArray[k++].attrVal);
				lo.hisAttrValList = abArray;
				lo.newAttrValList = new AttributeValue[0];
				
				BusinessObject bo = null;
				bo = bos.get(lo.fromOid);
				if (bo != null) {
					BOAndLO obj = new BOAndLO();
					obj.bo = bo;
					obj.btmName = bo.btName;
					obj.lo = lo;
					obj.ltName = lo.ltName;
					objList.add(obj);
				}
			}
			return objList;
		}catch(Throwable e){
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00009", e);
		}
		
	}
	
	/**
	 * 查询出链接对象, 根据版本版次条件拼接上业务对象
	 * @param clauseList
	 * @param sql
	 * @param queryType
	 * @return
	 * @throws VCIError
	 */
	public List<BOAndLO> findBOAndLOListCRCV(List<String> clauseList, String sql, Map<String, BusinessObject> bos) throws VCIError{
		try{
			Session session = HibernateSessionFactory.getSession();
			List<BOAndLO> objList = new ArrayList<BOAndLO>();
			SQLQuery sqlquery = session.createSQLQuery(sql);
			//根据查询模板中的查询列clauseList, 设置map
			
			List<?> list = sqlquery.list();
			for(int i = 0; i < list.size(); i++){
				
				LinkObject lo = new LinkObject();
				AttributeValue[] abArray = null;
				//当list.get(i)中有多个Object时, 类型为Object[]
				//必须先判断Object[] 在判断Object
//				if(list.get(i) instanceof Object[]){
					Object[] objs = (Object[])list.get(i);
					abArray = new AttributeValue[clauseList.size()];
					for(int k = 0; k < clauseList.size(); k++){
						AttributeValue ab = new AttributeValue();
						//sessin查询出的值
						Object value = objs[k];
						//clauseList中对应的查询列
						String abName = clauseList.get(k);
						if(abName.contains(".")){
							abName = abName.substring(abName.indexOf(".") + 1);
						//abName: CONNECT_BY_ISLEAF --> _ISLEAF
						}else if(abName.equals("CONNECT_BY_ISLEAF")){
							abName = "_ISLEAF";
						}else if(abName.equals("LEVEL")){
							abName = "_LEVEL";
						}
						
						ab.attrName = abName;
						ab.attrVal = String.valueOf(value == null ? "" : value);
						abArray[k] = ab;
					}
				//当list.get(i)中只有一个Object时, 类型为Object
//				}else{
					//sessin查询出的值
//					Object obj = list.get(i);
					//clauseList中对应的查询列
//					String abName = clauseList.get(0);
//					if(abName.contains(".")){
//						abName = abName.substring(abName.indexOf(".") + 1);
//					}
//					abArray = new AttributeValue[1];
//					AttributeValue ab = new AttributeValue();
//					ab.attrName = abName;
//					ab.attrVal = String.valueOf(obj == null ? "" : obj);
//					abArray[0] = ab;
//				}
				//为link的系统属性赋值
				int k = 0;
				lo.oid = abArray[k++].attrVal;
				lo.creator = abArray[k++].attrVal;
				lo.createTime = Integer.valueOf(abArray[k++].attrVal);
				lo.modifier = abArray[k++].attrVal;
				lo.modifyTime = Integer.valueOf(abArray[k++].attrVal);
				lo.fromOid = abArray[k++].attrVal;
				lo.fromRevOid = abArray[k++].attrVal;
				lo.fromNameOid = abArray[k++].attrVal;
				lo.fromBTName = abArray[k++].attrVal;
				lo.toOid = abArray[k++].attrVal;
				lo.toRevOid = abArray[k++].attrVal;
				lo.toNameOid = abArray[k++].attrVal;
				lo.toBTName = abArray[k++].attrVal;
				lo.ts = Integer.valueOf(abArray[k++].attrVal);
				lo.hisAttrValList = abArray;
				lo.newAttrValList = new AttributeValue[0];
				
				BusinessObject bo = null;
				bo = bos.get(lo.toOid);
				if (bo != null) {
					BOAndLO obj = new BOAndLO();
					obj.bo = bo;
					obj.btmName = bo.btName;
					obj.lo = lo;
					obj.ltName = lo.ltName;
					objList.add(obj);
				}
			}
			return objList;
		}catch(Throwable e){
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00009", e);
		}
		
	}
	
	/**
	 * 将业务类型的全部属性加上别名返回,用作查询列。
	 * 解决Hiberbate的覆盖同名查询列的值的问题。
	 * btmTableName.abName as abName2
	 * 避免别名后标识符过长(超过30), oracle查询出错
	 * @param btmName
	 * @return
	 * @throws Throwable 
	 */
	private List<String> getAllBtmFiledsWithAlias(String btmName) throws Throwable {
		try{
			List<String> list = new ArrayList<String>();
			List<String> abList = new ArrayList<String>();
			abList = getAllAbNamesForBtm(btmName);
			String btmTableName = OmdHelper.getBTTableName(btmName);
			for(int i = 0; i < abList.size(); i++){
				String abName = abList.get(i).trim();
				list.add(btmTableName + "." + abName + " AS " + abName + "2");
			}
			return list;
		}catch(Throwable e){
			throw e;
		}
	}
	
	/**
	 * 将链接类型的全部属性加上表明返回, 用作查询列;
	 * 避免与业务类型做链接查询时, 出现列明不明确问题.
	 * tableName.ltName
	 * @param ltName
	 * @param tableName
	 * @return
	 * @throws Throwable
	 */
	private List<String> getAllLinkTypeFiledsWithTableName(String ltName ,String tableName) throws Throwable{
		try{
			List<String> abList = new ArrayList<String>();
			String[] sysAbs = LinkConstants.SELECT_CONSTANTS;
			for(int i = 0; i < sysAbs.length; i++){
				abList.add(tableName + "." + sysAbs[i]);
			}
			//LinkType linkType = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(ltName);
			LinkType linkType = OMCacheProvider.getLinkType(ltName);
			String[] abs = linkType.attributes;
			for(int i = 0; i < abs.length; i++){
				abList.add(tableName + "." + abs[i].trim());
			}
			return abList;
		}catch(Throwable e){
			e.printStackTrace();
			throw e;
		}
	}
	
	//**************************************分段策略来实现递归查询**********************************************
	
	public List<LinkObject> findLinkObjectByPartion(QueryTemplate qt) throws Throwable{
		List<String> clauseList = qt.getClauseList();
		String ltName = qt.getLinkType();
		String ltTableName = OmdHelper.getLTTableName(ltName);
		clauseList = getAllLinkTypeFiledsWithTableName(ltName, ltTableName);
		clauseList.add("CONNECT_BY_ISLEAF");
		clauseList.add("LEVEL");
		qt.setClauseList(clauseList);
		Parser parser = new Parser(qt);
		String sql = parser.getLinkQuerySql();
		
		List<LinkObject> los = null;
		
		int version = qt.getVersion();
		//Version.currentRevLastVer, Version.lastRevLastVer需要替换版本版次
		los = executeSqlForLinkOnly(clauseList, sql, ltName);
		int recReturnMode = qt.getRecReturnMode();
		//对查询结果进行过滤
		if(recReturnMode == QTConstants.RECRETURNMODE_FILTER){
			los = filterLos(los);
		}
		if(version == Version.currentRevLastVer){
			Map<String, BusinessObject> boMap = getBoOIDSByPartionCRLV(qt, los);
			return replaceLink(los, boMap, version);
		}else if(version == Version.lastRevLastVer){
			Map<String, BusinessObject> boMap = getBoOIDSByPartionLRLV(qt, los);
			return replaceLink(los, boMap, version);
		//currentRevCurrentVer 虽不需要替换版本版次, 但有bo条件时需要用bo过滤lo
		}else{
			//String btmConditionSql = qt.getCondition().getBtmConditionSql(qt, true);
			String btmConditionSql = QTSqlUtil.getBtmConditionSql(qt, true);
			if(btmConditionSql != null && !btmConditionSql.equals("")){
				Map<String, BusinessObject> boMap = getBoOIDSByPartionOtherRV(qt, los, version);
				return replaceLink(los, boMap, version);
			}else{
				return los;
			}
		}
	}
	
	/**
	 * 按不同类型的revisionOid分组查询获取Map<revisionOid, BusinessObject>
	 * 当同一个类型中的revisionOid数量大于PARTIONSIZE时, 按照PARTIONSIZE分批查询
	 * @return
	 * @throws Throwable 
	 */
	public Map<String, BusinessObject> getBosByPartionCRLV(QueryTemplate qt, List<LinkObject> los) throws Throwable{
		Map<String, BusinessObject> bos = new HashMap<String, BusinessObject>();
		Map<String, List<String>> map = new HashMap<String, List<String>>();
		LinkObject lo = null;
		// revisionOid按照类型分组
		for (int i = 0; i < los.size(); i++) {
			lo = los.get(i);
			String key = lo.toBTName;
			String value = lo.toRevOid;
			List<String> list = map.get(key);
			if (list == null) {
				list = new ArrayList<String>();
				map.put(key, list);
			}
			if (!list.contains(value)) {
				list.add(value);
			}
		}
		
		//按不同类型的revisionOid分组查询
		for(Iterator<String> ite = map.keySet().iterator(); ite.hasNext();){
			String btmName = ite.next();
			List<String> revisionOidList = map.get(btmName);
			List<String> clauseList = getAllAbNamesForBtm(btmName);
			qt.setClauseList(clauseList);
			qt.setBtmType(btmName);
			Parser parser = new Parser(qt);
			String sql_ = parser.getBtmQuerySql();
			sql_ += " and REVISIONOID IN (";
			int size = revisionOidList.size();
			StringBuilder stb = null;
			for(int k = 0; k < size/PARTIONSIZE + 1; k++){
				stb = new StringBuilder(sql_);
				for(int m = k * PARTIONSIZE; m < (k + 1) * PARTIONSIZE && m < size; m++){
					stb.append("'");
					stb.append(revisionOidList.get(m));
					stb.append("'");
					stb.append(",");
				}
				String sql = stb.substring(0, stb.lastIndexOf(",")) + ")";
				bos.putAll(executeSqlForBtmCRLV(clauseList, sql));
			}
		}
		return bos;
	}
	
	public Map<String, BusinessObject> getBosByPartionLRLV(QueryTemplate qt, List<LinkObject> los) throws Throwable{
		Map<String, BusinessObject> bos = new HashMap<String, BusinessObject>();
		Map<String, List<String>> map = new HashMap<String, List<String>>();
		LinkObject lo = null;
		// NameOid按照类型分组
		for (int i = 0; i < los.size(); i++) {
			lo = los.get(i);
			String key = lo.toBTName;
			String value = lo.toNameOid;
			List<String> list = map.get(key);
			if (list == null) {
				list = new ArrayList<String>();
				map.put(key, list);
			}
			if (!list.contains(value)) {
				list.add(value);
			}
		}
		
		//按不同类型的NameOid分组查询
		for(Iterator<String> ite = map.keySet().iterator(); ite.hasNext();){
			String btmName = ite.next();
			List<String> nameOidList = map.get(btmName);
			List<String> clauseList = getAllAbNamesForBtm(btmName);
			qt.setClauseList(clauseList);
			qt.setBtmType(btmName);
			Parser parser = new Parser(qt);
			String sql_ = parser.getBtmQuerySql();
			sql_ += " and NAMEOID IN (";
			int size = nameOidList.size();
			StringBuilder stb = null;
			for(int k = 0; k < size/PARTIONSIZE + 1; k++){
				stb = new StringBuilder(sql_);
				for(int m = k * PARTIONSIZE; m < (k + 1) * PARTIONSIZE && m < size; m++){
					stb.append("'");
					stb.append(nameOidList.get(m));
					stb.append("'");
					stb.append(",");
				}
				String sql = stb.substring(0, stb.lastIndexOf(",")) + ")";
				bos.putAll(executeSqlForBtmLRLV(clauseList, sql));
			}
		}
		return bos;
	}
	
	public Map<String, BusinessObject> getBosByPartionOtherRV(QueryTemplate qt, List<LinkObject> los, int version) throws Throwable{
		Map<String, BusinessObject> bos = new HashMap<String, BusinessObject>();
		Map<String, List<String>> map = new HashMap<String, List<String>>();
		LinkObject lo = null;
		// Oid按照类型分组
		if(version == Version.currentRevCurrentVer){
			for (int i = 0; i < los.size(); i++) {
				lo = los.get(i);
				String key = lo.toBTName;
				String value = lo.toOid;
				List<String> list = map.get(key);
				if (list == null) {
					list = new ArrayList<String>();
					map.put(key, list);
				}
				if (!list.contains(value)) {
					list.add(value);
				}
			}
		}else{
			for (int i = 0; i < los.size(); i++) {
				lo = los.get(i);
				String key = lo.fromBTName;
				String value = lo.fromOid;
				List<String> list = map.get(key);
				if (list == null) {
					list = new ArrayList<String>();
					map.put(key, list);
				}
				if (!list.contains(value)) {
					list.add(value);
				}
			}
		}
		
		
		//按不同类型的Oid分组查询
		for(Iterator<String> ite = map.keySet().iterator(); ite.hasNext();){
			String btmName = ite.next();
			List<String> nameOidList = map.get(btmName);
			List<String> clauseList = getAllAbNamesForBtm(btmName);
			qt.setClauseList(clauseList);
			qt.setBtmType(btmName);
			Parser parser = new Parser(qt);
			String sql_ = parser.getBtmQuerySql();
			sql_ += " and OID IN (";
			int size = nameOidList.size();
			StringBuilder stb = null;
			for(int k = 0; k < size/PARTIONSIZE + 1; k++){
				stb = new StringBuilder(sql_);
				for(int m = k * PARTIONSIZE; m < (k + 1) * PARTIONSIZE && m < size; m++){
					stb.append("'");
					stb.append(nameOidList.get(m));
					stb.append("'");
					stb.append(",");
				}
				String sql = stb.substring(0, stb.lastIndexOf(",")) + ")";
				bos.putAll(executeSqlForBtmOtherRV(clauseList, sql));
			}
		}
		return bos;
	}
	
	/**
	 * 按不同类型的revisionOid分组查询获取Map<revisionOid, BusinessObject>
	 * 当同一个类型中的revisionOid数量大于PARTIONSIZE时, 按照PARTIONSIZE分批查询
	 * @return
	 * @throws Throwable 
	 */
	public Map<String, BusinessObject> getBoOIDSByPartionCRLV(QueryTemplate qt, List<LinkObject> los) throws Throwable{
		Map<String, BusinessObject> bos = new HashMap<String, BusinessObject>();
		Map<String, List<String>> map = new HashMap<String, List<String>>();
		LinkObject lo = null;
		// revisionOid按照类型分组
		for (int i = 0; i < los.size(); i++) {
			lo = los.get(i);
			String key = lo.toBTName;
			String value = lo.toRevOid;
			List<String> list = map.get(key);
			if (list == null) {
				list = new ArrayList<String>();
				map.put(key, list);
			}
			if (!list.contains(value)) {
				list.add(value);
			}
		}
		
		//按不同类型的revisionOid分组查询
		for(Iterator<String> ite = map.keySet().iterator(); ite.hasNext();){
			String btmName = ite.next();
			List<String> revisionOidList = map.get(btmName);
			List<String> clauseList = new ArrayList<String>();
			clauseList.add("OID");
			clauseList.add("REVISIONOID");
			clauseList.add("NAMEOID");
			qt.setClauseList(clauseList);
			qt.setBtmType(btmName);
			Parser parser = new Parser(qt);
			String sql_ = parser.getBtmQuerySql();
			sql_ += " and REVISIONOID IN (";
			int size = revisionOidList.size();
			StringBuilder stb = null;
			for(int k = 0; k < size/PARTIONSIZE + 1; k++){
				stb = new StringBuilder(sql_);
				for(int m = k * PARTIONSIZE; m < (k + 1) * PARTIONSIZE && m < size; m++){
					stb.append("'");
					stb.append(revisionOidList.get(m));
					stb.append("'");
					stb.append(",");
				}
				String sql = stb.substring(0, stb.lastIndexOf(",")) + ")";
				bos.putAll(executeSqlForBtmOIDS(sql, Version.currentRevLastVer));
			}
		}
		return bos;
	}
	
	public Map<String, BusinessObject> getBoOIDSByPartionLRLV(QueryTemplate qt, List<LinkObject> los) throws Throwable{
		Map<String, BusinessObject> bos = new HashMap<String, BusinessObject>();
		Map<String, List<String>> map = new HashMap<String, List<String>>();
		LinkObject lo = null;
		// nameOid按照类型分组
		for (int i = 0; i < los.size(); i++) {
			lo = los.get(i);
			String key = lo.toBTName;
			String value = lo.toNameOid;
			List<String> list = map.get(key);
			if (list == null) {
				list = new ArrayList<String>();
				map.put(key, list);
			}
			if (!list.contains(value)) {
				list.add(value);
			}
		}
		
		//按不同类型的revisionOid分组查询
		for(Iterator<String> ite = map.keySet().iterator(); ite.hasNext();){
			String btmName = ite.next();
			List<String> revisionOidList = map.get(btmName);
			List<String> clauseList = new ArrayList<String>();
			clauseList.add("OID");
			clauseList.add("REVISIONOID");
			clauseList.add("NAMEOID");
			qt.setClauseList(clauseList);
			qt.setBtmType(btmName);
			Parser parser = new Parser(qt);
			String sql_ = parser.getBtmQuerySql();
			sql_ += " and NAMEOID IN (";
			int size = revisionOidList.size();
			StringBuilder stb = null;
			for(int k = 0; k < size/PARTIONSIZE + 1; k++){
				stb = new StringBuilder(sql_);
				for(int m = k * PARTIONSIZE; m < (k + 1) * PARTIONSIZE && m < size; m++){
					stb.append("'");
					stb.append(revisionOidList.get(m));
					stb.append("'");
					stb.append(",");
				}
				String sql = stb.substring(0, stb.lastIndexOf(",")) + ")";
				bos.putAll(executeSqlForBtmOIDS(sql, Version.lastRevLastVer));
			}
		}
		return bos;
	}
	
	public Map<String, BusinessObject> getBoOIDSByPartionOtherRV(QueryTemplate qt, List<LinkObject> los, int version) throws Throwable{
		Map<String, BusinessObject> bos = new HashMap<String, BusinessObject>();
		Map<String, List<String>> map = new HashMap<String, List<String>>();
		LinkObject lo = null;
		// Oid按照类型分组
		if(version == Version.currentRevCurrentVer){
			for (int i = 0; i < los.size(); i++) {
				lo = los.get(i);
				String key = lo.toBTName;
				String value = lo.toOid;
				List<String> list = map.get(key);
				if (list == null) {
					list = new ArrayList<String>();
					map.put(key, list);
				}
				if (!list.contains(value)) {
					list.add(value);
				}
			}
		}else{
			for (int i = 0; i < los.size(); i++) {
				lo = los.get(i);
				String key = lo.fromBTName;
				String value = lo.fromOid;
				List<String> list = map.get(key);
				if (list == null) {
					list = new ArrayList<String>();
					map.put(key, list);
				}
				if (!list.contains(value)) {
					list.add(value);
				}
			}
		}
		
		
		//按不同类型的Oid分组查询
		for(Iterator<String> ite = map.keySet().iterator(); ite.hasNext();){
			String btmName = ite.next();
			List<String> revisionOidList = map.get(btmName);
			List<String> clauseList = new ArrayList<String>();
			clauseList.add("OID");
			clauseList.add("REVISIONOID");
			clauseList.add("NAMEOID");
			qt.setClauseList(clauseList);
			qt.setBtmType(btmName);
			Parser parser = new Parser(qt);
			String sql_ = parser.getBtmQuerySql();
			sql_ += " and OID IN (";
			int size = revisionOidList.size();
			StringBuilder stb = null;
			for(int k = 0; k < size/PARTIONSIZE + 1; k++){
				stb = new StringBuilder(sql_);
				for(int m = k * PARTIONSIZE; m < (k + 1) * PARTIONSIZE && m < size; m++){
					stb.append("'");
					stb.append(revisionOidList.get(m));
					stb.append("'");
					stb.append(",");
				}
				String sql = stb.substring(0, stb.lastIndexOf(",")) + ")";
				bos.putAll(executeSqlForBtmOIDS(sql, version));
			}
		}
		return bos;
	}
	
	/**
	 * 根据版本版次信息, 替换link的t_oid, t_RevisionOid
	 * 过滤lo
	 * @param los
	 * @param boMap
	 * @return
	 */
	private List<LinkObject> replaceLink(List<LinkObject> los,
			Map<String, BusinessObject> boMap, int version) {
		List<LinkObject> los_ = new ArrayList<LinkObject>();
		if(version == Version.currentRevLastVer){
			for(int i = 0; i < los.size(); i++){
				LinkObject lo = los.get(i);
				BusinessObject bo = boMap.get(lo.toRevOid);
				if(bo != null){
					lo.toOid = bo.oid;
					los_.add(lo);
				}
			}
		}else if(version == Version.lastRevLastVer){
			for(int i = 0; i < los.size(); i++){
				LinkObject lo = los.get(i);
				BusinessObject bo = boMap.get(lo.toNameOid);
				if(bo != null){
					lo.toOid = bo.oid;
					lo.toRevOid = bo.revisionid;
					los_.add(lo);
				}
			}
		}else if(version == Version.currentRevCurrentVer){
			for(int i = 0; i < los.size(); i++){
				LinkObject lo = los.get(i);
				BusinessObject bo = boMap.get(lo.toOid);
				if(bo != null){
					los_.add(lo);
				}
			}
		//反向
		}else{
			for(int i = 0; i < los.size(); i++){
				LinkObject lo = los.get(i);
				BusinessObject bo = boMap.get(lo.fromOid);
				if(bo != null){
					los_.add(lo);
				}
			}
		}
		
		return los_;
	}
	
	public List<BOAndLO> findBOAndLOByPartion(QueryTemplate qt) throws Throwable{
		List<String> clauseList = qt.getClauseList();
		String ltName = qt.getLinkType();
		String ltTableName = OmdHelper.getLTTableName(ltName);
		clauseList = getAllLinkTypeFiledsWithTableName(ltName, ltTableName);
		clauseList.add("CONNECT_BY_ISLEAF");
		clauseList.add("LEVEL");
		qt.setClauseList(clauseList);
		Parser parser = new Parser(qt);
		String sql = parser.getLinkQuerySql();
		
		List<LinkObject> los = executeSqlForLinkOnly(clauseList, sql, ltName);
		
		int recReturnMode = qt.getRecReturnMode();
		//对查询结果进行过滤
		if(recReturnMode == QTConstants.RECRETURNMODE_FILTER){
			los = filterLos(los);
		}
		
		int version = qt.getVersion();
		
		//查询业务对象 ---end---
		if(version == Version.lastRevLastVer){
//			los = findBOAndLOListLRLV(clauseList, sql, bos);
			Map<String, BusinessObject> boMap = getBosByPartionLRLV(qt, los);
			return combinationBOAndLO(los, boMap, version);
		}else if(version == Version.currentRevLastVer){
			Map<String, BusinessObject> boMap = getBosByPartionCRLV(qt, los);
			return combinationBOAndLO(los, boMap, version);
		}else{
//			los = findBOAndLOListOpposite(clauseList, sql, bos);
			Map<String, BusinessObject> boMap = getBosByPartionOtherRV(qt, los, version);
			return combinationBOAndLO(los, boMap, version);
		}
	}
	private List<BOAndLO> combinationBOAndLO(List<LinkObject> los,
			Map<String, BusinessObject> boMap, int version) {
		List<BOAndLO> list = new ArrayList<BOAndLO>();
		if(version == Version.currentRevLastVer){
			for(int i = 0; i < los.size(); i++){
				LinkObject lo = los.get(i);
				BusinessObject bo = boMap.get(lo.toRevOid);
				if(bo != null){
					BOAndLO obj = new BOAndLO();
					obj.bo = bo;
					obj.btmName = bo.btName;
					obj.lo = lo;
					obj.ltName = lo.ltName;
					list.add(obj);
				}
			}
		}else if(version == Version.lastRevLastVer){
			for(int i = 0; i < los.size(); i++){
				LinkObject lo = los.get(i);
				BusinessObject bo = boMap.get(lo.toNameOid);
				if(bo != null){
					BOAndLO obj = new BOAndLO();
					obj.bo = bo;
					obj.btmName = bo.btName;
					obj.lo = lo;
					obj.ltName = lo.ltName;
					list.add(obj);
				}
			}
		}else if(version == Version.currentRevCurrentVer){
			for(int i = 0; i < los.size(); i++){
				LinkObject lo = los.get(i);
				BusinessObject bo = boMap.get(lo.toOid);
				if(bo != null){
					BOAndLO obj = new BOAndLO();
					obj.bo = bo;
					obj.btmName = bo.btName;
					obj.lo = lo;
					obj.ltName = lo.ltName;
					list.add(obj);
				}
			}
		}else{
			for(int i = 0; i < los.size(); i++){
				LinkObject lo = los.get(i);
				BusinessObject bo = boMap.get(lo.fromOid);
				if(bo != null){
					BOAndLO obj = new BOAndLO();
					obj.bo = bo;
					obj.btmName = bo.btName;
					obj.lo = lo;
					obj.ltName = lo.ltName;
					list.add(obj);
				}
			}
		}
		
		return list;
	}

	/**
	 * 对查询结果进行过滤
	 * @param los
	 */
	public List<LinkObject> filterLos(List<LinkObject> los) {
		List<LinkObject> list = new ArrayList<LinkObject>();
		Map<String, String> map = new HashMap<String, String>();
		for(LinkObject lo : los){
			if(!map.containsKey(lo.oid)){
				list.add(lo);
				map.put(lo.oid, lo.oid);
			}
		}
		return list;
	}
	
	/**
	 * 对查询结果进行过滤
	 * @param list
	 * @return
	 */
	public List<BOAndLO> filterLoAndBOs(List<BOAndLO> loAndBos) {
		List<BOAndLO> list = new ArrayList<BOAndLO>();
		Map<String, String> map = new HashMap<String, String>();
		for(BOAndLO loAndBo : loAndBos){
			if(!map.containsKey(loAndBo.lo.oid)){
				list.add(loAndBo);
				map.put(loAndBo.lo.oid, loAndBo.lo.oid);
			}
		}
		return list;
	}
}