package com.vci.server.query.service;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.Reader;
import java.lang.reflect.Field;
import java.math.BigDecimal;
import java.sql.Clob;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorCompletionService;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.apache.commons.lang3.StringUtils;
import org.hibernate.SQLQuery;
import org.hibernate.Session;
import org.hibernate.transform.Transformers;
import org.omg.CORBA.IntHolder;

import com.vci.omd.constants.BusinessConstants;
import com.vci.omd.constants.LinkConstants;
import com.vci.omd.constants.SystemAttribute;
import com.vci.server.base.exception.ExceptionLocalHandler;
import com.vci.server.base.persistence.dao.HibernateSessionFactory;
import com.vci.server.base.utility.OQueryHelper;
import com.vci.server.base.utility.OmdHelper;
import com.vci.server.cache.OMCacheProvider;
import com.vci.server.query.parsers.BtmRefQueryParser;
import com.vci.server.query.parsers.Parser;
import com.vci.server.query.parsers.ParserForOneLevel;
import com.vci.server.query.util.ServerTool;
import com.vci.corba.omd.atm.AttPoolServicePrx;
import com.vci.corba.omd.atm.AttribItem;
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.corba.query.data.BtmRefQueryOption;
import com.vci.common.exception.VciExceptionTool;
import com.vci.common.log.ServerWithLog4j;
import com.vci.common.qt.object.QTConstants;
import com.vci.common.qt.object.QueryTemplate;
import com.vci.common.qt.object.Symbol;
import com.vci.common.utility.ObjectUtility;
import com.vci.corba.common.VCIError;

/**
 * 创建link的业务类型视图的查询策略 从linkTable和btmView查询，递归查询时不需要二次查询。
 * 
 * @author Administrator
 *
 */
public class QueryObjectService {
	private static QueryObjectService queryObj = null;
	private int nCpu = Runtime.getRuntime().availableProcessors();

	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 QueryObjectService getInstance() {
		if (queryObj == null) {
			queryObj = new QueryObjectService();
		}
		return queryObj;
	}

	/**
	 * 解析QueryTemplate 为sql 执行sql, 返回结果
	 * 
	 * @param queryTemplate
	 * @return
	 * @throws Throwable
	 */
	public List<BusinessObject> findBtmObjects(QueryTemplate queryTemplate) throws Throwable {
		return this.findBtmObjectsV2(queryTemplate, new IntHolder(0));
	}

	/**
	 * 解析QueryTemplate 为sql 执行sql, 返回结果 V2版
	 * 
	 * @param queryTemplate
	 * @param count         查询结果的总数，通过 count.value 获取
	 * @return 查询到的业务类型数据 <code>com.vci.corba.omd.BusinessObject</code>
	 * @since v1.1 2017.08.31
	 * @see com.vci.corba.omd.data.BusinessObject
	 * @throws Throwable
	 */
	public List<BusinessObject> findBtmObjectsV2(QueryTemplate queryTemplate, IntHolder count) throws Throwable {
		List<BtmRefQueryOption> refOpts = new ArrayList<BtmRefQueryOption>();
		List<String> clauseList = queryTemplate.getClauseList();
		// 当clauseList中含有*时, 应当解析为BtmObject的全部属性
		if (clauseList.contains("*") || queryTemplate.isQueryChildren()) {
			clauseList = getAllAbNamesForBtm(queryTemplate.getBtmType());
		} else if (clauseList.size() > 0) {
			// add by xchao 2017.12.20 begin
			boolean hasRefQuery = false;
			List<String> list = queryTemplate.getClauseList();
			Iterator<String> its = list.iterator();
			while (its.hasNext()) {
				String clause = its.next();
				if (clause.indexOf(".") >= 0) {
					if (!hasRefQuery) {
						hasRefQuery = true;
					}
					String[] kvs = clause.split("\\.");
					int len = kvs.length;
					if (len == 2) {
						// 一层参照 a.b
						// 第二个参数给空，是此不处从属性中查其参数的业务类型，由下下专用掊中进行处理
						BtmRefQueryOption refOpt = new BtmRefQueryOption(kvs[0], "", new String[] { kvs[1] });
						refOpts.add(refOpt);
					} else if (len == 3) {
						// 二层参照 a.b.c
						// TODO
					} else {
						// 三层以的参照 a.b.c.d a.b.c.d.e
						// TODO
					}
					its.remove();
				}
			}
			clauseList = list;
			queryTemplate.setClauseList(clauseList);
			if (hasRefQuery) {
				return this.findBtmObjectsV3(queryTemplate, count, refOpts.toArray(new BtmRefQueryOption[0]));
			}
			// add by xchao 2017.12.20 end

			clauseList = getSelectedAbNamesForBtm(queryTemplate.getBtmType(), queryTemplate.getClauseList());
		}
		Parser parser = new Parser(queryTemplate);
		// add by xchao 2017.09.04 BEGIN
		// 添加总数特殊标识
		clauseList.add(QTConstants.COUNT_OVER_ALIAS);
		// add by xchao 2017.09.04 END
		queryTemplate.setClauseList(clauseList);
		String sql = parser.parseToSql();
		// 解析sql后， 去掉clauseList中加的表名
		clauseList = removeTableName(clauseList);
		List<BusinessObject> objList = executeSqlForBtmAndClauseV2(clauseList, sql, count, parser);
		return objList;
	}

	/**
	 * 解析QueryTemplate 为sql 执行sql, 返回结果 V3版：基于传入指定参照查询规则进行查询参照对象数据
	 * 
	 * @param queryTemplate
	 * @param count              查询结果的总数，通过 count.value 获取
	 * @param btmRefQueryOptions 参照查询选项参数
	 * @return 查询到的业务类型数据 <code>com.vci.corba.omd.BusinessObject</code>
	 * @since 2017.12.20
	 * @author xiongchao
	 * @see com.vci.corba.omd.data.BusinessObject
	 * @throws Throwable
	 */
	public List<BusinessObject> findBtmObjectsV3(QueryTemplate queryTemplate, IntHolder count,
			BtmRefQueryOption[] btmRefQueryOptions) throws Throwable {
		final List<String> joinOnTables = new ArrayList<String>();
		final Map<String, String> refBtmNameMap = new HashMap<String, String>();
		Map<String, Integer> refSameBtmNameMap = new HashMap<String, Integer>();
		Map<String, Set<String>> refSameBtmNameAttrMap = new HashMap<String, Set<String>>();
		// 参照业务类型查询列与别名之间的映射
		final Map<String, String> refBtmQueryAttrToAliasMap = new HashMap<String, String>();
		final Map<String, String> refBtmQueryAliasToAttrMap = new HashMap<String, String>();
		// 不需要表名的clause
		final Map<String, String> dotRemoveTableNameClauseMap = new HashMap<String, String>();

		List<String> clauseList = queryTemplate.getClauseList();
		// 当clauseList中含有*时, 应当解析为BtmObject的全部属性
		if (clauseList.contains("*") || queryTemplate.isQueryChildren()) {
			return this.findBtmObjectsV2(queryTemplate, count);
//			clauseList = getAllAbNamesForBtm(queryTemplate.getBtmType());
		} else if (clauseList.size() > 0) {
			String btmTableName = OmdHelper.getBTTableName(queryTemplate.getBtmType());
			List<String> list = queryTemplate.getClauseList();
			// 对 参照属性进行处理
			for (BtmRefQueryOption refOpt : btmRefQueryOptions) {
				if (StringUtils.isEmpty(refOpt.attrName)) {
					continue;
				}
				// 参照的业务类型为空
				if (StringUtils.isEmpty(refOpt.refBtmName)) {
					// 根据属性，从属性池关系中查出参照的业务类型
					String refBtmName = getAttrRefBtmName(refOpt.attrName);
					if (StringUtils.isEmpty(refBtmName)) {
						continue;
					}
					refOpt.refBtmName = refBtmName;
				}
				if (refOpt.refBtmQueryAttrs.length == 0) {
					continue;
				}
				//
				String refBtmTable = OmdHelper.getBTTableName(refOpt.refBtmName);
				// modify by weidy@2021-1-20 把1.2版本的参照查询转移过来，解决参照是自己这个业务类型的时候报错的问题，比如部门里的上级部门属性
				String trueRefTable = refBtmTable.toLowerCase();
				if (btmTableName.equals(refBtmTable)) {// 瑙ｅ喅寮曠敤鏈韩鐨勬椂鍊�
					refBtmTable = refBtmTable.replace("PLATFORM", "") + "_1";
				}
				if (refSameBtmNameMap.containsKey(refBtmTable)) {
					// 这个业务类型里有多个属性的是参照当前业务类型的
					int max = 0;
					if (refSameBtmNameMap.containsKey(refBtmTable)) {
						max = refSameBtmNameMap.get(refBtmTable);
					}
					boolean isNewReferTable = true;
					if (refSameBtmNameAttrMap.containsKey(refBtmTable)) {
						Set<String> attrSet = refSameBtmNameAttrMap.get(refBtmTable);
						if (attrSet.contains(refOpt.attrName.trim().toLowerCase())) {
							isNewReferTable = false;
						} else {
							attrSet.add(refOpt.attrName.trim().toLowerCase());
						}
						refSameBtmNameAttrMap.put(refBtmTable, attrSet);
					}
					if (isNewReferTable) {
						refSameBtmNameMap.put(refBtmTable, max + 1);
						refBtmTable = String.valueOf((char) ('A' + (max + 1)));
					}
				} else {
					Set<String> attrSet = new HashSet<String>();
					attrSet.add(refOpt.attrName.trim().toLowerCase());
					refSameBtmNameAttrMap.put(refBtmTable, attrSet);
					refSameBtmNameMap.put(refBtmTable, 1);
				}
				for (String refBtmAttr : refOpt.refBtmQueryAttrs) {
					// 处理参照
					String queryField = (refBtmTable + "." + refBtmAttr).toLowerCase();
					char c = (char) (65 + refBtmQueryAttrToAliasMap.size() + 1);
					String alias = (String.valueOf(c) + "__" + refBtmAttr).toLowerCase();
					String aliasColumnName = (refOpt.attrName + "." + refBtmAttr).toLowerCase();// 鐢ㄤ簬杩斿洖缁欏墠绔�
					refBtmQueryAttrToAliasMap.put(queryField, alias);
					refBtmQueryAliasToAttrMap.put(alias, aliasColumnName);
					list.add(queryField);

					// 昵称
					String key = getAppendAliasClause(queryField, alias);
					dotRemoveTableNameClauseMap.put(key, key);
				}
				if (!refBtmNameMap.containsKey(refBtmTable)) {
					StringBuffer sb = new StringBuffer();
					sb.append(Symbol.SPACE);
					sb.append(Symbol.LEFT_JOIN);
					sb.append(Symbol.SPACE);
					sb.append(trueRefTable);
					sb.append(Symbol.SPACE);
					sb.append(refBtmTable.toLowerCase());
					sb.append(Symbol.SPACE);
					sb.append(Symbol.ON);
					sb.append(Symbol.SPACE);
					sb.append(refBtmTable.toLowerCase() + ".oid=");
					sb.append(btmTableName + ".");
					sb.append(refOpt.attrName);
					sb.append(Symbol.SPACE);
					joinOnTables.add(sb.toString());
					refBtmNameMap.put(refBtmTable, refOpt.refBtmName);
				}
			}
			queryTemplate.setClauseList(list);
			clauseList = getSelectedAbNamesForBtmV3(queryTemplate.getBtmType(), queryTemplate.getClauseList(),
					refBtmQueryAttrToAliasMap);
		}
		Parser parser = new BtmRefQueryParser(queryTemplate) {
			@Override
			public String getQueryType() {
				// 重写 构建表关联的逻辑段
				String res = super.getQueryType();
				if (joinOnTables.size() > 0) {
					StringBuffer sb = new StringBuffer(res);
					for (String string : joinOnTables) {
						sb.append(Symbol.SPACE).append(string);
					}
					sb.append(Symbol.SPACE);
					res = sb.toString();
				}
				return res;
			}
		};
		// add by xchao 2017.09.04 BEGIN
		// 添加总数特殊标识
		clauseList.add(QTConstants.COUNT_OVER_ALIAS);
		// add by xchao 2017.09.04 END
		queryTemplate.setClauseList(clauseList);
		String sql = parser.parseToSql();
		// 解析sql后， 去掉clauseList中加的表名
		clauseList = removeTableNameV3(clauseList, dotRemoveTableNameClauseMap);
		List<BusinessObject> objList = executeSqlForBtmAndClauseV3(clauseList, sql, count, parser,
				refBtmQueryAliasToAttrMap);
		return objList;
	}

	//private AttPoolServicePrx apImpl = null;
	private Map<String, AttribItem> apMap = new HashMap<String, AttribItem>();

	protected String getAttrRefBtmName(String attrName) throws VCIError {
		String[] others = getAttribItem(attrName).other.split(";");
		for (String string : others) {
			String[] kvs = string.split("=");
			String key = kvs[0].trim();
			String val = kvs[1].trim();
			if ("btm".equalsIgnoreCase(key)) {
				return val;
			}
		}
		return "";
	}

	protected AttribItem getAttribItem(String attrName) throws VCIError {
//		if (apImpl == null) {
//			apImpl = ServerServiceProvider.getOMDService().getAttributeService();
//		}
		AttribItem ai = apMap.get(attrName);
		if (ai == null) {
			//ai = apImpl.getAttribItemByName(attrName);
			ai = OMCacheProvider.getAttribute(attrName);
			apMap.put(attrName, ai);
		}
		return ai;
	}

	/**
	 * @param clauseList
	 * @param sql
	 * @return
	 */
	private List<BusinessObject> executeSqlForBtmAndClauseV3(List<String> clauseList, String sql, IntHolder count,
			Parser parser, Map<String, String> refBtmQueryAliasToAttrMap) {
		List<BusinessObject> objList = new ArrayList<BusinessObject>();
		Session session = HibernateSessionFactory.getSession();
		ServerWithLog4j.logger.debug(sql);
		SQLQuery sqlquery = session.createSQLQuery(sql);
		// 根据查询模板中的查询列clauseList, 设置map
		List<?> list = sqlquery.list();
		String countOverAlias = QTConstants.COUNT_OVER_ALIAS;
		int countValue = 0;
		
		Map<String, String> mapValue = new HashMap<String, String>();
		for (int i = 0; i < list.size(); i++) {
			BusinessObject bo = new BusinessObject();
			List<AttributeValue> abList = new ArrayList<AttributeValue>();
			// 当list.get(i)中有多个Object时, 类型为Object[]
			// 必须先判断Object[] 再判断Object
			Object[] objs = (Object[]) list.get(i);
			mapValue.clear();
			for (int k = 0; k < clauseList.size(); k++) {
				String clauseField = clauseList.get(k);
				if (countOverAlias.equalsIgnoreCase(clauseField)) {
					countValue = Integer.valueOf(objs[k].toString());
					if (count == null) {
						count = new IntHolder();
					}
					count.value = countValue;
					continue;
				}
				AttributeValue ab = new AttributeValue();
				// sessin查询出的值
				Object value = objs[k];
				// clauseList中对应的查询列
				String abName = clauseField;
				if (clauseField.indexOf("'' as ") > -1) {// 对不存在的列的名字做修饰，因为查询时是以 “'' as 列名”查询的
					abName = abName.substring(abName.lastIndexOf("'' as ") + "'' as ".length());
				}
				// add by xchao 2017.12.20 begin
				// 参照数据查询列，专用处理
				String asChar = " as ";
				// 分解出“别名”
				int asPos = clauseField.indexOf(asChar);
				if (asPos >= 0) {
					abName = clauseField.substring(asPos + asChar.length());
				}
				// 基于 别名与 提取出 原始 配置的（查询模板中原始传入的 clauseList中的 ，如 xxx.name）
				String orignalField = refBtmQueryAliasToAttrMap.get(abName);
				// 如果值不为空，则添加到 AttributeValue
				if (StringUtils.isNotEmpty(orignalField)) {
					abName = orignalField;
				}
				// add by xchao 2017.12.20 end

				ab.attrName = abName;
				// 如果是clob字段，转换字符串
				ab.attrVal = objValueToString(value);
				abList.add(ab);
				mapValue.put(ab.attrName.toLowerCase(), ab.attrVal);
			}
			AttributeValue[] abArray = abList.toArray(new AttributeValue[0]);
			bo.newAttrValList = new AttributeValue[0];
			bo.hisAttrValList = abArray;
			// 为btm的系统属性赋值
			// 改为动态根据查出列的数量赋值
			setBOAttribute(bo, mapValue);
			
			objList.add(bo);
		}
		return objList;
	}

	private String objValueToString(Object value) {
		if (value == null)
			return "";
		
		if (value instanceof Clob) {
			return clobToString((Clob) value);
		} else if (value instanceof java.sql.Timestamp) {
			java.sql.Timestamp ts = (java.sql.Timestamp)value;
			return String.valueOf(ts.getTime());
		} else if (value instanceof java.sql.Date) {
			java.sql.Date date = (java.sql.Date)value;
			return String.valueOf(date.getTime());
		} else {
			return String.valueOf(value);
		}
	}

	private void setBOAttribute(BusinessObject bo, Map<String, String> mapValue) {
		Field[] fields = bo.getClass().getFields();
		for (Field f : fields) {
			// 只甄选基本类型
			if (!f.getType().isPrimitive() && !f.getType().equals(String.class))
				continue;
			
			f.setAccessible(true);
			String name = f.getName();
			if (name.equalsIgnoreCase("BTNAME"))
				name = "BTMNAME";
			else if (name.equalsIgnoreCase("MODIFIER"))
				name = "LASTMODIFIER";
			else if (name.equalsIgnoreCase("MODIFYTIME"))
				name = "LASTMODIFYTIME";
			else if (name.equalsIgnoreCase("FROMVERSION"))
				name = "COPYFROMVERSION";
			else if (name.equalsIgnoreCase("REVISIONOID"))
				name = "revisionid";
			
			name = name.toLowerCase();
			// f.getType().equals(String.class)
			if (mapValue.containsKey(name)) {
				String value = mapValue.get(name);
				
				try {
					if (f.getType().equals(String.class)) {
						f.set(bo, value);
					} else if (f.getType().equals(boolean.class)) {
						f.set(bo, StringUtils.isBlank(value) ? false : Integer.valueOf(value) != 0);
					} else if (f.getType().equals(short.class)) {
						f.set(bo, StringUtils.isBlank(value) ? 0 : Short.valueOf(value));
					} else if (f.getType().equals(int.class)) {
						f.set(bo, StringUtils.isBlank(value) ? 0 : Integer.valueOf(value));
					} else if (f.getType().equals(long.class) && value != null && value.length() > 0) {
						f.set(bo, StringUtils.isBlank(value) ? 0 : Long.valueOf(value));
					}
				} catch (IllegalArgumentException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				} catch (IllegalAccessException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
//			try {
//				if (f.getName().equalsIgnoreCase(abArray[j].attrName)) {
//					if (f.getType().equals(String.class)) {
//						f.set(bo, abArray[j].attrVal);
//					} else if (f.getType().equals(int.class) && abArray[j].attrVal != null
//							&& abArray[j].attrVal.length() > 0) {
//						f.set(bo, Integer.valueOf(abArray[j].attrVal));
//					}
//					continue outer;
//					// 对象中属性名为revisionid，但是数据库字段名为revisionoid，反射不能正确匹配，所以特别匹配下
//				} else if (f.getName().equalsIgnoreCase("revisionid")
//						&& abArray[j].attrName.equalsIgnoreCase("REVISIONOID")) {
//					f.set(bo, abArray[j].attrVal);
//				}
//			} catch (Exception e) {
//				e.printStackTrace();
//			}
		}
	}

	/**
	 * @param clauseList
	 * @param sql
	 * @return
	 */
	private List<BusinessObject> executeSqlForBtmAndClauseV2(List<String> clauseList, String sql, IntHolder count,
			Parser parser) {
		List<BusinessObject> objList = new ArrayList<BusinessObject>();
		Session session = HibernateSessionFactory.getSession();
		ServerWithLog4j.logger.debug(sql);
		SQLQuery sqlquery = session.createSQLQuery(sql);
		// 根据查询模板中的查询列clauseList, 设置map
		List<?> list = sqlquery.list();
		String countOverAlias = QTConstants.COUNT_OVER_ALIAS;
		int countValue = 0;
		Map<String, String> mapValue = new HashMap<String, String>();
		for (int i = 0; i < list.size(); i++) {
			BusinessObject bo = new BusinessObject();
			List<AttributeValue> abList = new ArrayList<AttributeValue>();
			// 当list.get(i)中有多个Object时, 类型为Object[]
			// 必须先判断Object[] 再判断Object
			
			mapValue.clear();
			Object[] objs = (Object[]) list.get(i);
			for (int k = 0; k < clauseList.size(); k++) {
				String clauseField = clauseList.get(k);
				if (countOverAlias.equalsIgnoreCase(clauseField)) {
					countValue = Integer.valueOf(objs[k].toString());
					if (count == null) {
						count = new IntHolder();
					}
					count.value = countValue;
					continue;
				}
				AttributeValue ab = new AttributeValue();
				// sessin查询出的值
				Object value = objs[k];
				// clauseList中对应的查询列
				String abName = clauseList.get(k);
				if (clauseList.get(k).indexOf("'' as ") > -1) {// 对不存在的列的名字做修饰，因为查询时是以 “'' as 列名”查询的
					abName = abName.substring(abName.lastIndexOf("'' as ") + "'' as ".length());
				}
				ab.attrName = abName;
				ab.attrVal = objValueToString(value);
				abList.add(ab);
				mapValue.put(ab.attrName.toLowerCase(), ab.attrVal);
			}
			AttributeValue[] abArray = abList.toArray(new AttributeValue[0]);
			bo.newAttrValList = new AttributeValue[0];
			bo.hisAttrValList = abArray;
			// 为btm的系统属性赋值
			// 改为动态根据查出列的数量赋值
			setBOAttribute(bo, mapValue);
//			Field[] fields = bo.getClass().getFields();
//			outer: for (int j = 0; j < abArray.length; j++) {
//				for (Field f : fields) {
//					// System.out.println(f.getName()+","+f.getType().equals(int.class));
//					// 只甄选基本类型和字符串类型
//					if (f.getType().isPrimitive() || f.getType().equals(String.class)) {
//						f.setAccessible(true);
//						try {
//							if (f.getName().equalsIgnoreCase(abArray[j].attrName)) {
//								if (f.getType().equals(String.class)) {
//									f.set(bo, abArray[j].attrVal);
//								} else if (f.getType().equals(int.class) && abArray[j].attrVal != null
//										&& abArray[j].attrVal.length() > 0) {
//									f.set(bo, Integer.valueOf(abArray[j].attrVal));
//								}
//								continue outer;
//								// 对象中属性名为revisionid，但是数据库字段名为revisionoid，反射不能正确匹配，所以特别匹配下
//							} else if (f.getName().equalsIgnoreCase("revisionid")
//									&& abArray[j].attrName.equalsIgnoreCase("REVISIONOID")) {
//								f.set(bo, abArray[j].attrVal);
//							}
//						} catch (Exception e) {
//							e.printStackTrace();
//						}
//					}
//				}
//			}
			objList.add(bo);
		}
		return objList;
	}

	/**
	 * clob转String
	 * 
	 * @param value
	 * @return
	 */
	private String clobToString(Clob value) {
		// TODO Auto-generated method stub
		String clobValue = "";
		try {
			Reader is = value.getCharacterStream();
			BufferedReader br = new BufferedReader(is);
			String s = br.readLine();
			StringBuffer sb = new StringBuffer();
			while (s != null) {
				sb.append(s);
				s = br.readLine();
			}
			clobValue = sb.toString();
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

		return clobValue;
	}

	/**
	 * 解析QueryTemplate 为sql 执行sql, 返回结果
	 * 
	 * @param queryTemplate
	 * @return
	 * @throws VCIError
	 */
	public List<LinkObject> findLinkObject(QueryTemplate queryTemplate) throws Throwable {
		return this.findLinkObjectV2(queryTemplate, new IntHolder(0));
	}

	/**
	 * 解析QueryTemplate 为sql 执行sql, 返回结果
	 * 
	 * @param queryTemplate
	 * @param count         查询结果的总数，通过 count.value 获取
	 * @return 查询到的业务类型数据 <code>com.vci.corba.omd.LinkObject</code>
	 * @since v1.1 2017.08.31
	 * @see com.vci.corba.omd.data.LinkObject
	 * @throws VCIError
	 */
	public List<LinkObject> findLinkObjectV2(QueryTemplate queryTemplate, IntHolder count) throws Throwable {
		List<String> clauseList = queryTemplate.getClauseList();
		String ltName = queryTemplate.getLinkType();
		String ltTableName = OmdHelper.getLTTableName(ltName);
		String btmName = queryTemplate.getBtmType();
		boolean btmFlag = false;
		if (clauseList.contains(ltTableName + ".*") || clauseList.contains("*") || clauseList.size() > 0) {
			if (!clauseList.contains(ltTableName + ".*") && !clauseList.contains("*")) {
				clauseList = this.getSelectedLinkTypeFiledsWithTableName(ltName, ltTableName, clauseList);
			} else {
				clauseList = getAllLinkTypeFiledsWithTableName(ltName, ltTableName);
			}
			if (btmName != null && !btmName.equals("")) {
				btmFlag = true;
				String viewName = null;
				if (btmName.equals("*") || btmName.contains(",")) {
					if (queryTemplate.getDirection().equals(QTConstants.DIRECTION_POSITIVE)) {
						viewName = OmdHelper.getToViewName(ltName);
					} else {
						viewName = OmdHelper.getFromViewName(ltName);
					}
				} else {
					viewName = OmdHelper.getBTTableName(btmName);
				}

				clauseList.add(viewName + ".OID AS OID2");
				clauseList.add(viewName + ".REVISIONOID AS REVISIONOID2");
			}
			clauseList.add("CONNECT_BY_ISLEAF");
			clauseList.add("LEVEL");
		}
		Parser parser = new Parser(queryTemplate);
		// add by xchao 2017.09.04 BEGIN
		// 添加总数列查询
		clauseList.add(QTConstants.COUNT_OVER_ALIAS);
		// add by xchao 2017.09.04 END
		queryTemplate.setClauseList(clauseList);
		String sql = parser.parseToSql();
		List<LinkObject> objList = null;
		clauseList = this.removeTableName(clauseList);
		if (btmFlag) {
			objList = executeSqlForLinkWithVersion(clauseList, sql, queryTemplate.getDirection(), ltName);
		} else {
			objList = executeSqlForLink(clauseList, sql, ltName);
		}
		return objList;
	}

	/**
	 * 查询一层, 分查询是否有有下一级和不查询是否有有下一级
	 * 
	 * @param queryTemplate
	 * @return
	 * @throws Throwable
	 */
	public List<LinkObject> findLinkObjectOneLevel(QueryTemplate queryTemplate) throws Throwable {
		return this.findLinkObjectOneLevelV2(queryTemplate, new IntHolder(0));
	}

	/**
	 * 查询一层, 分查询是否有有下一级和不查询是否有有下一级
	 * 
	 * @param queryTemplate
	 * @return
	 * @param count 查询结果的总数，通过 count.value 获取
	 * @return 查询到的业务类型数据 <code>com.vci.corba.omd.LinkObject</code>
	 * @since v1.1 2017.08.31
	 * @see com.vci.corba.omd.data.LinkObject
	 * @throws Throwable
	 */
	public List<LinkObject> findLinkObjectOneLevelV2(QueryTemplate queryTemplate, IntHolder count) throws Throwable {
		List<String> clauseList = queryTemplate.getClauseList();
		String ltName = queryTemplate.getLinkType();
		String ltTableName = OmdHelper.getLTTableName(ltName);
		String btmName = queryTemplate.getBtmType();
		boolean btmFlag = false;
		if (clauseList.contains(ltTableName + ".*") || clauseList.contains("*") || clauseList.size() > 0) {
			if (!clauseList.contains("*") && !clauseList.contains(ltTableName + ".*")) {
				clauseList = getSelectedLinkTypeFiledsWithTableName(ltName, ltTableName, clauseList);
			} else {
				clauseList = getAllLinkTypeFiledsWithTableName(ltName, ltTableName);
			}
			if (btmName != null && !btmName.equals("")) {
				btmFlag = true;
				String viewName = null;
				if (btmName.equals("*") || btmName.contains(",")) {
					if (queryTemplate.getDirection().equals(QTConstants.DIRECTION_POSITIVE)) {
						viewName = OmdHelper.getToViewName(ltName);
					} else {
						viewName = OmdHelper.getFromViewName(ltName);
					}
				} else {
					viewName = OmdHelper.getBTTableName(btmName);
				}
				clauseList.add(viewName + ".OID AS OID2");
				clauseList.add(viewName + ".REVISIONOID AS REVISIONOID2");
			}
		}
		ParserForOneLevel parser = new ParserForOneLevel(queryTemplate);
		// add by xhao 2017.09.04 BEGIN
		// 添加上总数特殊标识查询
		clauseList.add(QTConstants.COUNT_OVER_ALIAS);
		// add by xhao 2017.09.04 END
		queryTemplate.setClauseList(clauseList);
		String sql = parser.parseToSql();

		Map<String, String> isLeafMap = null;
		if (queryTemplate.isQueryISLeaf()) {
			String sql_ = parser.parseToSqlForLinkStartWith();
			isLeafMap = getIsLeaf(sql_);
		} else {
			isLeafMap = new HashMap<String, String>();
		}

		List<LinkObject> objList = null;
		clauseList = removeTableName(clauseList);
		if (btmFlag) {
			objList = executeSqlForLinkWithVersionOneLevelV2(clauseList, sql, queryTemplate.getDirection(), ltName,
					isLeafMap, count);
		} else {
			objList = executeSqlForLinkOneLevel(clauseList, sql, ltName, isLeafMap);
		}
		return objList;
	}

	/**
	 * 获取特定业务类型属性, 包括系统属性和属性池属性 如果‘要求列’不是确实存在的列，咋在返回值中添加 '' as 别名
	 * 
	 * @param btmName
	 * @param clauseList 返回列
	 * @return
	 * @throws Throwable
	 */
	private List<String> getSelectedAbNamesForBtm(String btmName, List<String> clauseList) throws Throwable {
		try {
			String tableName = OmdHelper.getBTTableName(btmName);
			// 系统属性
			String[] sysAbs = BusinessConstants.SELECT_CONSTANTS;
			List<String> sysList = new ArrayList<String>();
			List<String> abList = new ArrayList<String>();
			if (sysAbs != null && sysAbs.length > 0) {
				for (String sysAb : sysAbs) {
					String abLower = sysAb.toLowerCase();
					sysList.add(abLower);
					abList.add(tableName + "." + abLower);
				}
			}
			// 属性池属性
			//String[] abs = ServerServiceProvider.getOMDService().getBTMService().getBtmApNameArray(btmName);// OmdTools.getAbNames(btmName);
			String[] abs = OMCacheProvider.getBTAttributes(btmName);
			List<String> absList = new ArrayList<String>();
			if (abs != null && abs.length > 0) {
				for (String ab : abs) {
					absList.add(ab.toLowerCase());
				}
			}
			for (int i = 0; i < clauseList.size(); i++) {
				// 如果传入的clauseList确实存在于系统属性或属性池属性中，则保留，否则按“'' as 别名”查询
				String lowerCaseName = clauseList.get(i).toLowerCase();
				if (sysList.contains(lowerCaseName)) {
					continue;
				}
				if (absList.contains(lowerCaseName)) {
					abList.add(tableName + "." + clauseList.get(i));
				} else {
					abList.add("'' as " + clauseList.get(i));
				}
			}
			return abList;
		} catch (Throwable e) {
			e.printStackTrace();
			throw e;
		}
	}

	private List<String> getSelectedAbNamesForBtmV3(String btmName, List<String> clauseList,
			Map<String, String> refBtmQueryAttrToAliasMap) throws Throwable {
		try {
			String tableName = OmdHelper.getBTTableName(btmName);
			// 系统属性
			String[] sysAbs = BusinessConstants.SELECT_CONSTANTS;
			List<String> sysList = new ArrayList<String>();
			List<String> abList = new ArrayList<String>();
			if (sysAbs != null && sysAbs.length > 0) {
				for (String sysAb : sysAbs) {
					String abLower = sysAb.toLowerCase();
					sysList.add(abLower);
					abList.add(tableName + "." + abLower);
				}
			}
			// 属性池属性
			//String[] abs = ServerServiceProvider.getOMDService().getBTMService().getBtmApNameArray(btmName);// OmdTools.getAbNames(btmName);
			String[] abs = OMCacheProvider.getBTAttributes(btmName);
			List<String> absList = new ArrayList<String>();
			if (abs != null && abs.length > 0) {
				for (String ab : abs) {
					absList.add(ab.toLowerCase());
				}
			}
			for (int i = 0; i < clauseList.size(); i++) {
				String clauseString = clauseList.get(i);
				// 如果传入的clauseList确实存在于系统属性或属性池属性中，则保留，否则按“'' as 别名”查询
				String lowerCaseName = clauseString.toLowerCase();
				if (sysList.contains(lowerCaseName)) {
					continue;
				}
				if (absList.contains(lowerCaseName)) {
					abList.add(tableName + "." + clauseString);
				} else {
					String alias = refBtmQueryAttrToAliasMap.get(lowerCaseName);
					if (StringUtils.isNotEmpty(alias)) {
						abList.add(getAppendAliasClause(lowerCaseName, alias));
					}
				}
			}
			return abList;
		} catch (Throwable e) {
			e.printStackTrace();
			throw e;
		}
	}

	private String getAppendAliasClause(String clause, String alias) {
		return clause + " as " + alias;
	}

	/**
	 * 获取业务类型全部属性, 包括系统属性和属性池属性
	 * 
	 * @param btmName
	 * @return
	 * @throws Throwable
	 */
	private List<String> getAllAbNamesForBtm(String btmName) throws Throwable {
		try {
			String tableName = OmdHelper.getBTTableName(btmName);
			List<String> abList = new ArrayList<String>();
			String[] sysAbs = BusinessConstants.SELECT_CONSTANTS;
			for (int i = 0; i < sysAbs.length; i++) {
				abList.add(tableName + "." + sysAbs[i]);
			}
			//String[] abs = ServerServiceProvider.getOMDService().getBTMService().getBtmApNameArray(btmName);// OmdTools.getAbNames(btmName);
			String[] abs = OMCacheProvider.getBTAttributes(btmName);
			for (int i = 0; i < abs.length; i++) {
				abList.add(tableName + "." + abs[i]);
			}
			return abList;
		} catch (Throwable e) {
			e.printStackTrace();
			throw e;
		}
	}

	/**
	 * 解析sql后， 去掉clauseList中加的表名
	 * 
	 * @param clauseList
	 */
	private List<String> removeTableName(List<String> clauseList) {
		List<String> list = new ArrayList<String>(clauseList.size());
		for (String clause : clauseList) {
			if (clause.contains(".")) {
				clause = clause.substring(clause.lastIndexOf(".") + 1);
			}
			list.add(clause);
		}
		return list;
	}

	private List<String> removeTableNameV3(List<String> clauseList, Map<String, String> dotRemoveTableNameClauseMap) {
		List<String> list = new ArrayList<String>(clauseList.size());
		for (String clause : clauseList) {
			if (dotRemoveTableNameClauseMap.containsKey(clause)) {
				list.add(clause);
				continue;
			}
			if (clause.contains(".")) {
				clause = clause.substring(clause.lastIndexOf(".") + 1);
			}
			list.add(clause);
		}
		return list;
	}

	/**
	 * 将链接类型的全部属性加上表明返回, 用作查询列; 避免与业务类型做链接查询时, 出现列明不明确问题. tableName.ltName
	 * 
	 * @param ltName
	 * @param tableName
	 * @return
	 * @throws Throwable
	 */
	private List<String> getSelectedLinkTypeFiledsWithTableName(String ltName, String tableName,
			List<String> clauseList) throws Throwable {
		try {
			ServerWithLog4j.logger.debug("非全量查詢。。。。。。");
			String[] sysAbs = LinkConstants.SELECT_CONSTANTS;
			List<String> sysAbsList = new ArrayList<String>();
			if (sysAbs != null && sysAbs.length > 0) {
				sysAbsList = Arrays.asList(sysAbs);
			}
			//LinkType linkType = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(ltName);// LinkTypeProvider.getInstance().getLinkTypeByName(ltName);
			LinkType linkType = OMCacheProvider.getLinkType(ltName);
			String[] abs = linkType.attributes;
			List<String> absList = new ArrayList<String>();
			if (abs != null && abs.length > 0) {
				absList = Arrays.asList(abs);
			}
			List<String> abList = new ArrayList<String>();
			for (int i = 0; i < clauseList.size(); i++) {
				// 如果传入的clauseList确实存在于系统属性或属性池属性中，则保留，否则按“'' as 别名”查询
				if (sysAbsList.contains(clauseList.get(i)) || absList.contains(clauseList.get(i))) {
					abList.add(tableName + "." + clauseList.get(i));
				} else {
					abList.add("'' as " + clauseList.get(i));
				}
			}
			return abList;
		} catch (Throwable e) {
			e.printStackTrace();
			throw e;
		}
	}

	/**
	 * 将链接类型的全部属性加上表明返回, 用作查询列; 避免与业务类型做链接查询时, 出现列明不明确问题. tableName.ltName
	 * 
	 * @param ltName
	 * @param tableName
	 * @return
	 * @throws Throwable
	 */
	private List<String> getAllLinkTypeFiledsWithTableName(String ltName, String tableName) throws Throwable {
		//LinkType linkType = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(ltName);
		LinkType linkType = OMCacheProvider.getLinkType(ltName);
		return getAllLinkTypeFiledsWithTableName(linkType, tableName);
		/*
		 * 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 =
		 * ltService.getLinkType(ltName);//LinkTypeProvider.getInstance().
		 * getLinkTypeByName(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; }
		 */
	}

	/**
	 * 将链接类型的全部属性加上表明返回, 用作查询列; 避免与业务类型做链接查询时, 出现列明不明确问题. tableName.ltName
	 * 
	 * @param linkType  链接类型对象
	 * @param tableName
	 * @return
	 * @throws Throwable
	 */
	private List<String> getAllLinkTypeFiledsWithTableName(LinkType linkType, 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]);
			}
			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;
		}
	}

	/**
	 * 从linkTable和btmView查询BOAndLO
	 * 
	 * @param qt
	 * @return
	 * @throws Throwable
	 */
	public List<BOAndLO> findBOAndLOByView(QueryTemplate qt, String btmOId) throws Throwable {
		List<String> clauseList = qt.getClauseList();
		String ltName = qt.getLinkType();
		String btmName = qt.getBtmType();
		String ltTableName = OmdHelper.getLTTableName(ltName);
		clauseList = getAllLinkTypeFiledsWithTableName(ltName, ltTableName);
		clauseList.add("CONNECT_BY_ISLEAF");
		clauseList.add("LEVEL");
		List<String> viewCols = null;
		//LinkType linkType = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(ltName);// LinkTypeProvider.getInstance().getLinkTypeByName(ltName);
		LinkType linkType = OMCacheProvider.getLinkType(ltName);
		String viewName = null;
		if (btmName != null && !btmName.equals("*") && !btmName.contains(",")) {
			viewName = OmdHelper.getBTTableName(btmName);
		}

		if (viewName == null) {
			if (qt.getDirection().equals(QTConstants.DIRECTION_POSITIVE)) {
				viewCols = OQueryHelper.getViewColsWithAlias(linkType.btmItemsTo, OmdHelper.getToViewName(ltName));
			} else {
				viewCols = OQueryHelper.getViewColsWithAlias(linkType.btmItemsFrom, OmdHelper.getFromViewName(ltName));
			}

		} else {
			viewCols = OQueryHelper.getViewColsWithAlias(new String[] { btmName }, viewName);
		}
		clauseList.addAll(viewCols);
		qt.setClauseList(clauseList);
		Parser parser = new Parser(qt);
		String sql = parser.parseToSql();

		String key = "start with";
		if ((sql.toLowerCase().indexOf("start with") > 0) && StringUtils.isNotEmpty(btmOId)) {
			String f_oidCondition = " " + ltTableName + ".f_oid = '" + btmOId + "' and ";
			sql = sql.replace(key, key + f_oidCondition);
		}

		List<BOAndLO> boAndLos = executeSqlForBOAndLO(clauseList, sql, ltName, qt.getDirection());

		return boAndLos;

	}

	/**
	 * 查询一层, 分查询是否有有下一级和不查询是否有有下一级 从linkTable和btmView查询BOAndLO
	 * 
	 * @param qt
	 * @return
	 * @throws Throwable
	 */
	public List<BOAndLO> findBOAndLOByViewOneLevel(QueryTemplate qt) throws Throwable {
		List<String> clauseList = qt.getClauseList();
		String ltName = qt.getLinkType();
		String btmName = qt.getBtmType();
		String ltTableName = OmdHelper.getLTTableName(ltName);
		//LinkType linkType = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(ltName); // weidy@2018-6-26
		LinkType linkType = OMCacheProvider.getLinkType(ltName);
		clauseList = getAllLinkTypeFiledsWithTableName(linkType, ltTableName);
		List<String> viewCols = null;
		// LinkTypeProvider.getInstance().getLinkTypeByName(ltName);

		String viewName = null;
		if (btmName != null && !btmName.equals("*") && !btmName.contains(",")) {
			viewName = OmdHelper.getBTTableName(btmName);
		}

		if (viewName == null) {
			if (qt.getDirection().equals(QTConstants.DIRECTION_POSITIVE)) {
				viewCols = ServerTool.getViewColsWithAlias(linkType.btmItemsTo, OmdHelper.getToViewName(ltName));
			} else {
				viewCols = ServerTool.getViewColsWithAlias(linkType.btmItemsFrom, OmdHelper.getFromViewName(ltName));
			}

		} else {
			viewCols = ServerTool.getViewColsWithAlias(new String[] { btmName }, viewName);
		}

		clauseList.addAll(viewCols);
		qt.setClauseList(clauseList);
		ParserForOneLevel parser = new ParserForOneLevel(qt);
		String sql = parser.parseToSql();

		Map<String, String> isLeafMap = null;
		if (qt.isQueryISLeaf()) {
			String sql_ = parser.parseToSqlForLinkStartWith();
			isLeafMap = getIsLeaf(sql_);
		} else {
			isLeafMap = new HashMap<String, String>();
		}

		List<BOAndLO> boAndLos = executeSqlForBOAndLOOneLevel(clauseList, sql, ltName, qt.getDirection(), isLeafMap);

		return boAndLos;

	}

	/**
	 * 查询linkoid 是否有下一级
	 * 
	 * @param sql_
	 * @return
	 */
	private Map<String, String> getIsLeaf(String sql_) {
		Map<String, String> isLeafMap = new HashMap<String, String>();
		Session session = HibernateSessionFactory.getSession();
		ServerWithLog4j.logger.debug(sql_);
		SQLQuery sqlQuery = session.createSQLQuery(sql_);
		sqlQuery.setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP);
		List<?> list = sqlQuery.list();
		for (int i = 0; i < list.size(); i++) {
			Map<String, Object> map = (Map<String, Object>) list.get(i);
			String key = (String) map.get("OID");
			String val = String.valueOf(((BigDecimal) (map.get("CONNECT_BY_ISLEAF"))).intValue());
			isLeafMap.put(key, val);
		}
		return isLeafMap;
	}

	/**
	 * 查询链接类型
	 * 
	 * @param clauseList
	 * @param sql
	 * @param queryType
	 * @param direction
	 * @param ltName     : 目前系统属性没有ltName
	 * @return
	 * @throws VCIError
	 */
	public List<LinkObject> executeSqlForLink(List<String> clauseList, String sql, String ltName) throws VCIError {
		try {
			String[] ltSysAttrs = OmdHelper.getLTSysAbItems();
			//LinkType linkType = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(ltName);// LinkTypeProvider.getInstance().getLinkTypeByName(ltName);
			LinkType linkType = OMCacheProvider.getLinkType(ltName);
			String[] ltUserAttrs = linkType.attributes;
			// +2 for :CONNECT_BY_ISLEAF , LEVEL
			int loAttrSize = ltSysAttrs.length + ltUserAttrs.length + 2;

			List<LinkObject> objList = new ArrayList<LinkObject>();
			Session session = HibernateSessionFactory.getSession();
			ServerWithLog4j.logger.debug(sql);
			SQLQuery sqlQuery = session.createSQLQuery(sql);
			// 查询出的记录为Map<String, Object>的List集合
			sqlQuery.setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP);

			List<?> list = sqlQuery.list();
			for (int i = 0; i < list.size(); i++) {
				Map<String, Object> map = (Map<String, Object>) list.get(i);
				LinkObject lo = getLO(map, ltUserAttrs, ltName, loAttrSize, clauseList);
				objList.add(lo);
			}
			return objList;
		} catch (Throwable e) {
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00009", e);
		}

	}

	public List<LinkObject> executeSqlForLinkOneLevel(List<String> clauseList, String sql, String ltName,
			Map<String, String> isLeafMap) throws VCIError {
		try {
			String[] ltSysAttrs = OmdHelper.getLTSysAbItems();
			//LinkType linkType = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(ltName);// LinkTypeProvider.getInstance().getLinkTypeByName(ltName);
			LinkType linkType = OMCacheProvider.getLinkType(ltName);
			String[] ltUserAttrs = linkType.attributes;
			// +2 for :CONNECT_BY_ISLEAF , LEVEL
			int loAttrSize = ltSysAttrs.length + ltUserAttrs.length + 2;

			List<LinkObject> objList = new ArrayList<LinkObject>();
			Session session = HibernateSessionFactory.getSession();
			ServerWithLog4j.logger.debug(sql);
			SQLQuery sqlQuery = session.createSQLQuery(sql);
			// 查询出的记录为Map<String, Object>的List集合
			sqlQuery.setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP);

			List<?> list = sqlQuery.list();
			for (int i = 0; i < list.size(); i++) {
				Map<String, Object> map = (Map<String, Object>) list.get(i);
				LinkObject lo = getLOOneLevel(map, ltUserAttrs, ltName, loAttrSize, isLeafMap, clauseList);
				objList.add(lo);
			}
			return objList;
		} catch (Throwable e) {
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00009", e);
		}

	}

	/**
	 * 查询链接类型 正向查询时替换T_OId, T_RevisionOId
	 * 
	 * @param clauseList
	 * @param sql
	 * @param queryType
	 * @param direction
	 * @return
	 * @throws VCIError
	 */
	public List<LinkObject> executeSqlForLinkWithVersion(List<String> clauseList, String sql, String direction,
			String ltName) throws VCIError {
		try {
			ExecutorService exec = Executors.newFixedThreadPool(nCpu);
			ExecutorCompletionService<LinkObject> exec_ = new ExecutorCompletionService<LinkObject>(exec);

			String[] ltSysAttrs = OmdHelper.getLTSysAbItems();
			//LinkType linkType = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(ltName);// LinkTypeProvider.getInstance().getLinkTypeByName(ltName);
			LinkType linkType = OMCacheProvider.getLinkType(ltName);
			String[] ltUserAttrs = linkType.attributes;
			// +2 for :CONNECT_BY_ISLEAF , LEVEL
			int loAttrSize = ltSysAttrs.length + ltUserAttrs.length + 2;

			List<LinkObject> objList = new ArrayList<LinkObject>();
			Session session = HibernateSessionFactory.getSession();
			ServerWithLog4j.logger.debug(sql);
			SQLQuery sqlQuery = session.createSQLQuery(sql);
			// 查询出的记录为Map<String, Object>的List集合
			sqlQuery.setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP);
			List<?> list = sqlQuery.list();
			for (int i = 0; i < list.size(); i++) {
				Map<String, Object> map = (Map<String, Object>) list.get(i);
//				LinkObject lo = getLOWithVersion(map, direction, ltUserAttrs, ltName, loAttrSize);
//				objList.add(lo);
				exec_.submit(new QueryLOWithVersion(map, direction, ltUserAttrs, ltName, loAttrSize, clauseList));
			}
			for (int m = 0; m < list.size(); m++) {
				objList.add(exec_.take().get());
			}
			exec.shutdown();
			return objList;
		} catch (Throwable e) {
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00009", e);
		}

	}

	public List<LinkObject> executeSqlForLinkWithVersionOneLevel(List<String> clauseList, String sql, String direction,
			String ltName, Map<String, String> isLeafMap) throws VCIError {
		return this.executeSqlForLinkWithVersionOneLevelV2(clauseList, sql, direction, ltName, isLeafMap,
				new IntHolder(0));
	}

	public List<LinkObject> executeSqlForLinkWithVersionOneLevelV2(List<String> clauseList, String sql,
			String direction, String ltName, Map<String, String> isLeafMap, IntHolder count) throws VCIError {
		try {
			String[] ltSysAttrs = OmdHelper.getLTSysAbItems();
			//LinkType linkType = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(ltName);// LinkTypeProvider.getInstance().getLinkTypeByName(ltName);
			LinkType linkType = OMCacheProvider.getLinkType(ltName);
			String[] ltUserAttrs = linkType.attributes;
			// +2 for :CONNECT_BY_ISLEAF , LEVEL
			int loAttrSize = ltSysAttrs.length + ltUserAttrs.length + 2;

			List<LinkObject> objList = new ArrayList<LinkObject>();
			Session session = HibernateSessionFactory.getSession();
			ServerWithLog4j.logger.debug(sql);
			SQLQuery sqlQuery = session.createSQLQuery(sql);
			// 查询出的记录为Map<String, Object>的List集合
			sqlQuery.setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP);
			List<?> list = sqlQuery.list();
			for (int i = 0; i < list.size(); i++) {
				Map<String, Object> map = (Map<String, Object>) list.get(i);
				LinkObject lo = getLOWithVersionOneLevelV2(map, direction, ltUserAttrs, ltName, loAttrSize, isLeafMap,
						clauseList, count);
				objList.add(lo);
			}
			return objList;
		} catch (Throwable e) {
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00009", e);
		}

	}

	/**
	 * 从linkTable和btmView查询BOAndLO
	 * 
	 * @param clauseList
	 * @param sql
	 * @param queryType
	 * @param direction
	 * @param ltName     : 目前系统属性没有ltName
	 * @return
	 * @throws VCIError
	 */
	public List<BOAndLO> executeSqlForBOAndLO(List<String> clauseList, String sql, String ltName, String direction)
			throws VCIError {
		try {
			ExecutorService exec = Executors.newFixedThreadPool(nCpu);
			ServerWithLog4j.logger.debug("create exec");
			ExecutorCompletionService<BOAndLO> exec_ = new ExecutorCompletionService<BOAndLO>(exec);

			String[] btSysAttrs = OmdHelper.getBTSysANames();
			String[] ltSysAttrs = OmdHelper.getLTSysAbItems();
			//LinkType linkType = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(ltName); // LinkTypeProvider.getInstance().getLinkTypeByName(ltName);
			LinkType linkType = OMCacheProvider.getLinkType(ltName);
			String[] ltUserAttrs = linkType.attributes;
			// +2 for :CONNECT_BY_ISLEAF , LEVEL
			int loAttrSize = ltSysAttrs.length + ltUserAttrs.length + 2;
			int btSysAttrSize = btSysAttrs.length;
			// 缓存业务类型对应的用户属性
			Map<String, String[]> btUserAttrMap = new HashMap<String, String[]>();

			List<BOAndLO> boAndLoList = new ArrayList<BOAndLO>();
			Session session = HibernateSessionFactory.getSession();
			ServerWithLog4j.logger.debug(sql);
			SQLQuery sqlQuery = session.createSQLQuery(sql);
			// 查询出的记录为Map<String, Object>的List集合
			sqlQuery.setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP);
			List<?> list = sqlQuery.list();
			for (int i = 0; i < list.size(); i++) {
				// modify by weidy@2019-02-25,原来的方式在数据量大的时候，会造成大量线程，并且查询业务类型也会重复查询
				// 修改为。1，先行查询to端或者from端的业务类型包含的属性
				Map<String, Object> map = (Map<String, Object>) list.get(i);
				String btName = "";
				if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
					Object value = map.get(SystemAttribute.T_BTWNAME.text());
					btName = String.valueOf(value == null ? "" : value);
				} else {
					Object value = map.get(SystemAttribute.F_BTWNAME.text());
					btName = String.valueOf(value == null ? "" : value);
				}
				if (!btUserAttrMap.containsKey(btName)) {
					//String[] btUserAttrs = ServerServiceProvider.getOMDService().getBTMService().getBtmApNameArray(btName);// BtmProvider.getInstance().getAbNames(btName);
					String[] btUserAttrs  = OMCacheProvider.getBTAttributes(btName);
					btUserAttrMap.put(btName, btUserAttrs);
				}
			}
			for (int i = 0; i < list.size(); i++) {
				Map<String, Object> map = (Map<String, Object>) list.get(i);// 线程池已经是根据CPU的个数来执行的了
				exec_.submit(
						new QueryBOAndLO(map, direction, ltUserAttrs, ltName, loAttrSize, btUserAttrMap, btSysAttrSize));
			}
			for (int m = 0; m < list.size(); m++) {
				boAndLoList.add(exec_.take().get());
			}
			exec.shutdown();
			return boAndLoList;
		} catch (Throwable e) {
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00009", e);
		}

	}

	public List<BOAndLO> executeSqlForBOAndLOOneLevel(List<String> clauseList, String sql, String ltName,
			String direction, Map<String, String> isLeafMap) throws VCIError {
		try {
			String[] btSysAttrs = OmdHelper.getBTSysANames();
			String[] ltSysAttrs = OmdHelper.getLTSysAbItems();
			//LinkType linkType = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(ltName);// LinkTypeProvider.getInstance().getLinkTypeByName(ltName);
			LinkType linkType = OMCacheProvider.getLinkType(ltName);
			String[] ltUserAttrs = linkType.attributes;
			// +2 for :CONNECT_BY_ISLEAF , LEVEL
			int loAttrSize = ltSysAttrs.length + ltUserAttrs.length + 2;
			int btSysAttrSize = btSysAttrs.length;
			// 缓存业务类型对应的用户属性
			Map<String, String[]> btUserAttrMap = new HashMap<String, String[]>();

			List<BOAndLO> boAndLoList = new ArrayList<BOAndLO>();
			Session session = HibernateSessionFactory.getSession();
			ServerWithLog4j.logger.debug(sql);
			SQLQuery sqlQuery = session.createSQLQuery(sql);
			// 查询出的记录为Map<String, Object>的List集合
			sqlQuery.setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP);
			List<?> list = sqlQuery.list();
			for (int i = 0; i < list.size(); i++) {
				Map<String, Object> map = (Map<String, Object>) list.get(i);
				BOAndLO boAndLo = getBOAndLOOneLevel(map, direction, ltUserAttrs, ltName, loAttrSize, btUserAttrMap,
						btSysAttrSize, isLeafMap);
				boAndLoList.add(boAndLo);
			}
			return boAndLoList;
		} catch (Throwable e) {
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00009", e);
		}

	}

	/**
	 * 对查询结果进行过滤
	 * 
	 * @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;
	}

	/**
	 * 将一条查询出的记录封装成LO
	 * 
	 * @param map:         一条从linkTable查询出的记录
	 * @param ltUserAttrs: 链接类型的用户属性
	 * @param ltName:      链接类型
	 * @param loAttrSize:  链接类型的属性长度(系统属性+用户属性)
	 * @return
	 */
	@SuppressWarnings("unused")
	private LinkObject getLO(Map<String, Object> map, String[] ltUserAttrs, String ltName, int loAttrSize) {
		// 设置lo
		LinkObject lo = new LinkObject();
		AttributeValue[] loAttrArray = new AttributeValue[loAttrSize];
		// 为link的系统属性赋值
		int k = 0;
		String attrName = SystemAttribute.OID.text();
		Object value = map.get(attrName);
		lo.oid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.oid);

		attrName = SystemAttribute.CREATOR.text();
		value = map.get(attrName);
		lo.creator = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.creator);

		attrName = SystemAttribute.CREATETIME.text();
		value = map.get(attrName);
		lo.createTime = (int)(value == null ? 0 : value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.createTime));

		attrName = SystemAttribute.LASTMODIFIER.text();
		value = map.get(attrName);
		lo.modifier = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.modifier);

		attrName = SystemAttribute.LASTMODIFYTIME.text();
		value = map.get(attrName);
		lo.modifyTime = (int)(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.modifyTime));

		attrName = SystemAttribute.F_OID.text();
		value = map.get(attrName);
		lo.fromOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromOid);

		attrName = SystemAttribute.F_REVISIONOID.text();
		value = map.get(attrName);
		lo.fromRevOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromRevOid);

		attrName = SystemAttribute.F_NAMEOID.text();
		value = map.get(attrName);
		lo.fromNameOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromNameOid);

		attrName = SystemAttribute.F_BTWNAME.text();
		value = map.get(attrName);
		lo.fromBTName = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromBTName);

		attrName = SystemAttribute.T_OID.text();
		value = map.get(attrName);
		lo.toOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toOid);

		attrName = SystemAttribute.T_REVISIONOID.text();
		value = map.get(attrName);
		lo.toRevOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toRevOid);

		attrName = SystemAttribute.T_NAMEOID.text();
		value = map.get(attrName);
		lo.toNameOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toNameOid);

		attrName = SystemAttribute.T_BTWNAME.text();
		value = map.get(attrName);
		lo.toBTName = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toBTName);

		attrName = SystemAttribute.TS.text();
		value = map.get(attrName);
		lo.ts = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.ts));

		// lo自定义属性赋值
		for (String userAttr : ltUserAttrs) {
			attrName = userAttr.toUpperCase();
			value = map.get(attrName);
			loAttrArray[k++] = new AttributeValue(userAttr, getDbRetrunVal(value));
		}

		// 将CONNECT_BY_ISLEAF , LEVEL加入lo.hisAttrValList
		value = map.get("CONNECT_BY_ISLEAF");
		loAttrArray[k++] = new AttributeValue("_ISLEAF", String.valueOf(value == null ? "" : value));

		value = map.get("LEVEL");
		loAttrArray[k++] = new AttributeValue("_LEVEL", String.valueOf(value == null ? "" : value));

		lo.hisAttrValList = loAttrArray;
		lo.newAttrValList = new AttributeValue[0];
		// 目前系统属性没有ltName, 传参赋值
		lo.ltName = ltName;
		return lo;
	}

	/**
	 * 将一条查询出的记录封装成LO
	 * 
	 * @param map:         一条从linkTable查询出的记录
	 * @param ltUserAttrs: 链接类型的用户属性
	 * @param ltName:      链接类型
	 * @param loAttrSize:  链接类型的属性长度(系统属性+用户属性)
	 * @param clauseList   返回列
	 * @return
	 */
	private LinkObject getLO(Map<String, Object> map, String[] ltUserAttrs, String ltName, int loAttrSize,
			List<String> clauseList) {
		// 设置lo
		LinkObject lo = new LinkObject();
		// 为link的系统属性赋值
		List<AttributeValue> attrList = new ArrayList<AttributeValue>();
		AttributeValue[] loAttrArrayNew = new AttributeValue[clauseList.size()];
		for (int i = 0; i < clauseList.size(); i++) {
			String attrName = clauseList.get(i).toUpperCase();
			if (attrName.indexOf(" AS ") > -1) {
				attrName = attrName.substring(attrName.lastIndexOf(" AS ") + 4);
			}
			Object attrVal = map.get(attrName);
			if (!attrName.equals(SystemAttribute.REVISIONOID + "2") && !attrName.equals(SystemAttribute.OID + "2")) {
				String attrValStr = String.valueOf(attrVal == null ? "" : attrVal);
				attrList.add(new AttributeValue(attrName, attrValStr));
			}
		}

		String attrName = SystemAttribute.OID.text();
		Object value = map.get(attrName);
		lo.oid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.CREATOR.text();
		value = map.get(attrName);
		lo.creator = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.CREATETIME.text();
		value = map.get(attrName);
		lo.createTime = ObjectUtility.getTimeMillis(value);

		attrName = SystemAttribute.LASTMODIFIER.text();
		value = map.get(attrName);
		lo.modifier = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.LASTMODIFYTIME.text();
		value = map.get(attrName);
		lo.modifyTime = ObjectUtility.getTimeMillis(value);

		attrName = SystemAttribute.F_OID.text();
		value = map.get(attrName);
		lo.fromOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.F_REVISIONOID.text();
		value = map.get(attrName);
		lo.fromRevOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.F_NAMEOID.text();
		value = map.get(attrName);
		lo.fromNameOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.F_BTWNAME.text();
		value = map.get(attrName);
		lo.fromBTName = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.T_OID.text();
		value = map.get(attrName);
		lo.toOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.T_REVISIONOID.text();
		value = map.get(attrName);
		lo.toRevOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.T_NAMEOID.text();
		value = map.get(attrName);
		lo.toNameOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.T_BTWNAME.text();
		value = map.get(attrName);
		lo.toBTName = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.TS.text();
		value = map.get(attrName);
		lo.ts = ObjectUtility.getTimeMillis(value);

		// lo自定义属性赋值

		// 将CONNECT_BY_ISLEAF , LEVEL加入lo.hisAttrValList
		value = map.get("CONNECT_BY_ISLEAF");
		attrList.add(new AttributeValue("_ISLEAF", String.valueOf(value == null ? "" : value)));

		value = map.get("LEVEL");
		attrList.add(new AttributeValue("_LEVEL", String.valueOf(value == null ? "" : value)));

		loAttrArrayNew = attrList.toArray(new AttributeValue[0]);
		lo.hisAttrValList = loAttrArrayNew;
		lo.newAttrValList = new AttributeValue[0];
		// 目前系统属性没有ltName, 传参赋值
		lo.ltName = ltName;
		return lo;
	}


	@SuppressWarnings("unused")
	private LinkObject getLOOneLevel(Map<String, Object> map, String[] ltUserAttrs, String ltName, int loAttrSize,
			Map<String, String> isLeafMap) {
		// 设置lo
		LinkObject lo = new LinkObject();
		AttributeValue[] loAttrArray = new AttributeValue[loAttrSize];
		// 为link的系统属性赋值
		int k = 0;
		String attrName = SystemAttribute.OID.text();
		Object value = map.get(attrName);
		lo.oid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.oid);

		attrName = SystemAttribute.CREATOR.text();
		value = map.get(attrName);
		lo.creator = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.creator);

		attrName = SystemAttribute.CREATETIME.text();
		value = map.get(attrName);
		lo.createTime = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.createTime));

		attrName = SystemAttribute.LASTMODIFIER.text();
		value = map.get(attrName);
		lo.modifier = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.modifier);

		attrName = SystemAttribute.LASTMODIFYTIME.text();
		value = map.get(attrName);
		lo.modifyTime = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.modifyTime));

		attrName = SystemAttribute.F_OID.text();
		value = map.get(attrName);
		lo.fromOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromOid);

		attrName = SystemAttribute.F_REVISIONOID.text();
		value = map.get(attrName);
		lo.fromRevOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromRevOid);

		attrName = SystemAttribute.F_NAMEOID.text();
		value = map.get(attrName);
		lo.fromNameOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromNameOid);

		attrName = SystemAttribute.F_BTWNAME.text();
		value = map.get(attrName);
		lo.fromBTName = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromBTName);

		attrName = SystemAttribute.T_OID.text();
		value = map.get(attrName);
		lo.toOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toOid);

		attrName = SystemAttribute.T_REVISIONOID.text();
		value = map.get(attrName);
		lo.toRevOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toRevOid);

		attrName = SystemAttribute.T_NAMEOID.text();
		value = map.get(attrName);
		lo.toNameOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toNameOid);

		attrName = SystemAttribute.T_BTWNAME.text();
		value = map.get(attrName);
		lo.toBTName = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toBTName);

		attrName = SystemAttribute.TS.text();
		value = map.get(attrName);
		lo.ts = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.ts));

		// lo自定义属性赋值
		for (String userAttr : ltUserAttrs) {
			attrName = userAttr.toUpperCase();
			value = map.get(attrName);
			loAttrArray[k++] = new AttributeValue(userAttr, getDbRetrunVal(value));
		}

		// 将CONNECT_BY_ISLEAF , LEVEL加入lo.hisAttrValList
		value = isLeafMap.get(lo.oid);
		loAttrArray[k++] = new AttributeValue("_ISLEAF", String.valueOf(value == null ? "" : value));

		value = map.get("LEVEL");
		loAttrArray[k++] = new AttributeValue("_LEVEL", String.valueOf(value == null ? "" : value));

		lo.hisAttrValList = loAttrArray;
		lo.newAttrValList = new AttributeValue[0];
		// 目前系统属性没有ltName, 传参赋值
		lo.ltName = ltName;
		return lo;
	}

	private LinkObject getLOOneLevel(Map<String, Object> map, String[] ltUserAttrs, String ltName, int loAttrSize,
			Map<String, String> isLeafMap, List<String> clauseList) {
		// 设置lo
		LinkObject lo = new LinkObject();
		// 为link的系统属性赋值
		List<AttributeValue> attrList = new ArrayList<AttributeValue>();
		AttributeValue[] loAttrArrayNew = new AttributeValue[clauseList.size()];
		for (int i = 0; i < clauseList.size(); i++) {
			String attrName = clauseList.get(i).toUpperCase();
			if (attrName.indexOf(" AS ") > -1) {
				attrName = attrName.substring(attrName.lastIndexOf(" AS ") + 4);
			}
			Object attrVal = map.get(attrName);
			if (!attrName.equals(SystemAttribute.REVISIONOID + "2") && !attrName.equals(SystemAttribute.OID + "2")) {
				String attrValStr = String.valueOf(attrVal == null ? "" : attrVal);
				attrList.add(new AttributeValue(attrName, attrValStr));
			}
		}

		String attrName = SystemAttribute.OID.text();
		Object value = map.get(attrName);
		lo.oid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.CREATOR.text();
		value = map.get(attrName);
		lo.creator = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.CREATETIME.text();
		value = map.get(attrName);
		lo.createTime = ObjectUtility.getTimeMillis(value);

		attrName = SystemAttribute.LASTMODIFIER.text();
		value = map.get(attrName);
		lo.modifier = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.LASTMODIFYTIME.text();
		value = map.get(attrName);
		lo.modifyTime = ObjectUtility.getTimeMillis(value);

		attrName = SystemAttribute.F_OID.text();
		value = map.get(attrName);
		lo.fromOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.F_REVISIONOID.text();
		value = map.get(attrName);
		lo.fromRevOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.F_NAMEOID.text();
		value = map.get(attrName);
		lo.fromNameOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.F_BTWNAME.text();
		value = map.get(attrName);
		lo.fromBTName = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.T_OID.text();
		value = map.get(attrName);
		lo.toOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.T_REVISIONOID.text();
		value = map.get(attrName);
		lo.toRevOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.T_NAMEOID.text();
		value = map.get(attrName);
		lo.toNameOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.T_BTWNAME.text();
		value = map.get(attrName);
		lo.toBTName = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.TS.text();
		value = map.get(attrName);
		lo.ts = ObjectUtility.getTimeMillis(value);

		// 将CONNECT_BY_ISLEAF , LEVEL加入lo.hisAttrValList
		value = isLeafMap.get(lo.oid);
		attrList.add(new AttributeValue("_ISLEAF", String.valueOf(value == null ? "" : value)));
		value = map.get("LEVEL");
		attrList.add(new AttributeValue("_LEVEL", String.valueOf(value == null ? "" : value)));
		loAttrArrayNew = attrList.toArray(new AttributeValue[0]);
		lo.hisAttrValList = loAttrArrayNew;
		lo.newAttrValList = new AttributeValue[0];
		// 目前系统属性没有ltName, 传参赋值
		lo.ltName = ltName;
		return lo;
	}

	/**
	 * 将一条查询出的记录封装成LO, 用btmView.OID, btmView.REVISIONOID作t_oid, t_revisionOid
	 * 
	 * @param map:         一条从linkTable和btmView.OID, btmView.REVISIONOID查询出的记录
	 * @param direction:   链接查询的方向
	 * @param ltUserAttrs: 链接类型的用户属性
	 * @param ltName:      链接类型
	 * @param loAttrSize:  链接类型的属性长度(系统属性+用户属性)
	 * @return
	 */
	private LinkObject getLOWithVersion(Map<String, Object> map, String direction, String[] ltUserAttrs, String ltName,
			int loAttrSize) {
		// 设置lo
		LinkObject lo = new LinkObject();
		AttributeValue[] loAttrArray = new AttributeValue[loAttrSize];
		// 为link的系统属性赋值
		int k = 0;
		String attrName = SystemAttribute.OID.text();
		Object value = map.get(attrName);
		lo.oid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.oid);

		attrName = SystemAttribute.CREATOR.text();
		value = map.get(attrName);
		lo.creator = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.creator);

		attrName = SystemAttribute.CREATETIME.text();
		value = map.get(attrName);
		lo.createTime = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.createTime));

		attrName = SystemAttribute.LASTMODIFIER.text();
		value = map.get(attrName);
		lo.modifier = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.modifier);

		attrName = SystemAttribute.LASTMODIFYTIME.text();
		value = map.get(attrName);
		lo.modifyTime = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.modifyTime));

		attrName = SystemAttribute.F_OID.text();
		if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
			attrName = SystemAttribute.OID + "2";
		}
		value = map.get(attrName);
		lo.fromOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.F_OID.text(), lo.fromOid);

		attrName = SystemAttribute.F_REVISIONOID.text();
		if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
			attrName = SystemAttribute.REVISIONOID + "2";
		}
		value = map.get(attrName);
		lo.fromRevOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.F_REVISIONOID.text(), lo.fromRevOid);

		attrName = SystemAttribute.F_NAMEOID.text();
		value = map.get(attrName);
		lo.fromNameOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromNameOid);

		attrName = SystemAttribute.F_BTWNAME.text();
		value = map.get(attrName);
		lo.fromBTName = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromBTName);

		attrName = SystemAttribute.T_OID.text();
		if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
			attrName = SystemAttribute.OID + "2";
		}
		value = map.get(attrName);
		lo.toOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.T_OID.text(), lo.toOid);

		attrName = SystemAttribute.T_REVISIONOID.text();
		if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
			attrName = SystemAttribute.REVISIONOID + "2";
		}
		value = map.get(attrName);
		lo.toRevOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.T_REVISIONOID.text(), lo.toRevOid);

		attrName = SystemAttribute.T_NAMEOID.text();
		value = map.get(attrName);
		lo.toNameOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toNameOid);

		attrName = SystemAttribute.T_BTWNAME.text();
		value = map.get(attrName);
		lo.toBTName = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toBTName);

		attrName = SystemAttribute.TS.text();
		value = map.get(attrName);
		lo.ts = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.ts));

		// lo自定义属性赋值
		for (String userAttr : ltUserAttrs) {
			attrName = userAttr.toUpperCase();
			value = map.get(attrName);
			loAttrArray[k++] = new AttributeValue(userAttr, getDbRetrunVal(value));
		}

		// 将CONNECT_BY_ISLEAF , LEVEL加入lo.hisAttrValList
		value = map.get("CONNECT_BY_ISLEAF");
		loAttrArray[k++] = new AttributeValue("_ISLEAF", String.valueOf(value == null ? "" : value));

		value = map.get("LEVEL");
		loAttrArray[k++] = new AttributeValue("_LEVEL", String.valueOf(value == null ? "" : value));

		lo.hisAttrValList = loAttrArray;
		lo.newAttrValList = new AttributeValue[0];
		// 目前系统属性没有ltName, 传参赋值
		lo.ltName = ltName;
		return lo;
	}

	/**
	 * 将一条查询出的记录封装成LO, 用btmView.OID, btmView.REVISIONOID作t_oid, t_revisionOid
	 * 
	 * @param map
	 * @param direction
	 * @param ltUserAttrs
	 * @param ltName
	 * @param loAttrSize
	 * @param isLeafMap
	 * @return
	 */
	@SuppressWarnings("unused")
	private LinkObject getLOWithVersionOneLevel(Map<String, Object> map, String direction, String[] ltUserAttrs,
			String ltName, int loAttrSize, Map<String, String> isLeafMap) {
		// 设置lo
		LinkObject lo = new LinkObject();
		AttributeValue[] loAttrArray = new AttributeValue[loAttrSize];
		// 为link的系统属性赋值
		int k = 0;
		String attrName = SystemAttribute.OID.text();
		Object value = map.get(attrName);
		lo.oid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.oid);

		attrName = SystemAttribute.CREATOR.text();
		value = map.get(attrName);
		lo.creator = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.creator);

		attrName = SystemAttribute.CREATETIME.text();
		value = map.get(attrName);
		lo.createTime = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.createTime));

		attrName = SystemAttribute.LASTMODIFIER.text();
		value = map.get(attrName);
		lo.modifier = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.modifier);

		attrName = SystemAttribute.LASTMODIFYTIME.text();
		value = map.get(attrName);
		lo.modifyTime = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.modifyTime));

		attrName = SystemAttribute.F_OID.text();
		if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
			attrName = SystemAttribute.OID + "2";
		}
		value = map.get(attrName);
		lo.fromOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.F_OID.text(), lo.fromOid);

		attrName = SystemAttribute.F_REVISIONOID.text();
		if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
			attrName = SystemAttribute.REVISIONOID + "2";
		}
		value = map.get(attrName);
		lo.fromRevOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.F_REVISIONOID.text(), lo.fromRevOid);

		attrName = SystemAttribute.F_NAMEOID.text();
		value = map.get(attrName);
		lo.fromNameOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromNameOid);

		attrName = SystemAttribute.F_BTWNAME.text();
		value = map.get(attrName);
		lo.fromBTName = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromBTName);

		attrName = SystemAttribute.T_OID.text();
		if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
			attrName = SystemAttribute.OID + "2";
		}
		value = map.get(attrName);
		lo.toOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.T_OID.text(), lo.toOid);

		attrName = SystemAttribute.T_REVISIONOID.text();
		if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
			attrName = SystemAttribute.REVISIONOID + "2";
		}
		value = map.get(attrName);
		lo.toRevOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.T_REVISIONOID.text(), lo.toRevOid);

		attrName = SystemAttribute.T_NAMEOID.text();
		value = map.get(attrName);
		lo.toNameOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toNameOid);

		attrName = SystemAttribute.T_BTWNAME.text();
		value = map.get(attrName);
		lo.toBTName = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toBTName);

		attrName = SystemAttribute.TS.text();
		value = map.get(attrName);
		lo.ts = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.ts));

		// lo自定义属性赋值
		for (String userAttr : ltUserAttrs) {
			attrName = userAttr.toUpperCase();
			value = map.get(attrName);
			loAttrArray[k++] = new AttributeValue(userAttr, getDbRetrunVal(value));
		}

		// 将CONNECT_BY_ISLEAF , LEVEL加入lo.hisAttrValList
		value = isLeafMap.get(lo.oid);
		loAttrArray[k++] = new AttributeValue("_ISLEAF", String.valueOf(value == null ? "" : value));

		value = map.get("LEVEL");
		loAttrArray[k++] = new AttributeValue("_LEVEL", String.valueOf(value == null ? "" : value));

		lo.hisAttrValList = loAttrArray;
		lo.newAttrValList = new AttributeValue[0];
		// 目前系统属性没有ltName, 传参赋值
		lo.ltName = ltName;
		return lo;
	}

	/**
	 * add by liumh150909,更改为按列返回值 将一条查询出的记录封装成LO, 用btmView.OID,
	 * btmView.REVISIONOID作t_oid, t_revisionOid
	 * 
	 * @param map
	 * @param direction
	 * @param ltUserAttrs
	 * @param ltName
	 * @param loAttrSize
	 * @param isLeafMap
	 * @param clauseList
	 * @return
	 */
	private LinkObject getLOWithVersionOneLevel(Map<String, Object> map, String direction, String[] ltUserAttrs,
			String ltName, int loAttrSize, Map<String, String> isLeafMap, List<String> clauseList) {
		return this.getLOWithVersionOneLevelV2(map, direction, ltUserAttrs, ltName, loAttrSize, isLeafMap, clauseList,
				new IntHolder(0));
	}

	/**
	 * add by liumh150909,更改为按列返回值 将一条查询出的记录封装成LO, 用btmView.OID,
	 * btmView.REVISIONOID作t_oid, t_revisionOid
	 * 
	 * @param map
	 * @param direction
	 * @param ltUserAttrs
	 * @param ltName
	 * @param loAttrSize
	 * @param isLeafMap
	 * @param clauseList
	 * @return
	 */
	private LinkObject getLOWithVersionOneLevelV2(Map<String, Object> map, String direction, String[] ltUserAttrs,
			String ltName, int loAttrSize, Map<String, String> isLeafMap, List<String> clauseList, IntHolder count) {
		// 设置lo
		LinkObject lo = new LinkObject();
		// 为link的系统属性赋值
		List<AttributeValue> attrList = new ArrayList<AttributeValue>();
		AttributeValue[] loAttrArrayNew = new AttributeValue[clauseList.size()];
		for (int i = 0; i < clauseList.size(); i++) {
			String attrName = clauseList.get(i).toUpperCase();
			if (attrName.indexOf(" AS ") > -1) {
				attrName = attrName.substring(attrName.lastIndexOf(" AS ") + 4);
			}
			Object attrVal = map.get(attrName);
			if (attrName.equalsIgnoreCase(QTConstants.COUNT_OVER_ALIAS)) {
				int countValue = Integer.valueOf(attrVal.toString());
				if (count == null) {
					count = new IntHolder(0);
				}
				count.value = countValue;
				continue;
			}

			if (attrName.equalsIgnoreCase(SystemAttribute.F_OID.text())) {
				if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
					attrName = SystemAttribute.OID + "2";
				}
				attrVal = map.get(attrName);
				attrName = SystemAttribute.F_OID.text();
			} else if (attrName.equalsIgnoreCase(SystemAttribute.F_REVISIONOID.text())) {
				if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
					attrName = SystemAttribute.REVISIONOID + "2";
				}
				attrVal = map.get(attrName);
				attrName = SystemAttribute.F_REVISIONOID.text();
			} else if (attrName.equalsIgnoreCase(SystemAttribute.T_OID.text())) {
				if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
					attrName = SystemAttribute.OID + "2";
				}
				attrVal = map.get(attrName);
				attrName = SystemAttribute.T_OID.text();
			} else if (attrName.equalsIgnoreCase(SystemAttribute.T_REVISIONOID.text())) {
				if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
					attrName = SystemAttribute.REVISIONOID + "2";
				}
				attrVal = map.get(attrName);
				attrName = SystemAttribute.T_REVISIONOID.text();
			}

			if (!attrName.equals(SystemAttribute.REVISIONOID + "2") && !attrName.equals(SystemAttribute.OID + "2")) {
				String attrValStr = String.valueOf(attrVal == null ? "" : attrVal);
				attrList.add(new AttributeValue(attrName, attrValStr));
			}
		}
		String attrName = SystemAttribute.OID.text();
		Object value = map.get(attrName);
		lo.oid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.CREATOR.text();
		value = map.get(attrName);
		lo.creator = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.CREATETIME.text();
		value = map.get(attrName);
		lo.createTime = ObjectUtility.getTimeMillis(value);

		attrName = SystemAttribute.LASTMODIFIER.text();
		value = map.get(attrName);
		lo.modifier = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.LASTMODIFYTIME.text();
		value = map.get(attrName);
		lo.modifyTime = ObjectUtility.getTimeMillis(value);

		attrName = SystemAttribute.F_OID.text();
		if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
			attrName = SystemAttribute.OID + "2";
		}
		value = map.get(attrName);
		lo.fromOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.F_REVISIONOID.text();
		if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
			attrName = SystemAttribute.REVISIONOID + "2";
		}
		value = map.get(attrName);
		lo.fromRevOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.F_NAMEOID.text();
		value = map.get(attrName);
		lo.fromNameOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.F_BTWNAME.text();
		value = map.get(attrName);
		lo.fromBTName = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.T_OID.text();
		if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
			attrName = SystemAttribute.OID + "2";
		}
		value = map.get(attrName);
		lo.toOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.T_REVISIONOID.text();
		if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
			attrName = SystemAttribute.REVISIONOID + "2";
		}
		value = map.get(attrName);
		lo.toRevOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.T_NAMEOID.text();
		value = map.get(attrName);
		lo.toNameOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.T_BTWNAME.text();
		value = map.get(attrName);
		lo.toBTName = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.TS.text();
		value = map.get(attrName);
		lo.ts = ObjectUtility.getTimeMillis(value);

		// 将CONNECT_BY_ISLEAF , LEVEL加入lo.hisAttrValList
		value = isLeafMap.get(lo.oid);
		attrList.add(new AttributeValue("_ISLEAF", String.valueOf(value == null ? "" : value)));

		value = map.get("LEVEL");
		attrList.add(new AttributeValue("_LEVEL", String.valueOf(value == null ? "" : value)));

		loAttrArrayNew = attrList.toArray(new AttributeValue[0]);
		lo.hisAttrValList = loAttrArrayNew;
		lo.newAttrValList = new AttributeValue[0];
		// 目前系统属性没有ltName, 传参赋值
		lo.ltName = ltName;
		return lo;
	}

	/**
	 * 将一条查询出的记录封装成BOAndLO
	 * 
	 * @param map:           一条从linkTable和btmView查询出的记录
	 * @param direction:     链接查询的方向
	 * @param ltUserAttrs:   链接类型的用户属性
	 * @param ltName:        链接类型
	 * @param loAttrSize:    链接类型的属性长度(系统属性+用户属性)
	 * @param btUserAttrMap: 业务类型及其对应的用户属性Map
	 * @param btSysAttrSize: 业务类型的系统属性长度
	 * @return
	 */
	private BOAndLO getBOAndLO(Map<String, Object> map, String direction, String[] ltUserAttrs, String ltName,
			int loAttrSize, Map<String, String[]> btUserAttrMap, int btSysAttrSize) throws VCIError {
		// 设置lo
		LinkObject lo = new LinkObject();
		AttributeValue[] loAttrArray = new AttributeValue[loAttrSize];
		// 为link的系统属性赋值
		int k = 0;
		String attrName = SystemAttribute.OID.text();
		Object value = map.get(attrName);
		lo.oid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.oid);

		attrName = SystemAttribute.CREATOR.text();
		value = map.get(attrName);
		lo.creator = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.creator);

		attrName = SystemAttribute.CREATETIME.text();
		value = map.get(attrName);
		lo.createTime = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.createTime));

		attrName = SystemAttribute.LASTMODIFIER.text();
		value = map.get(attrName);
		lo.modifier = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.modifier);

		attrName = SystemAttribute.LASTMODIFYTIME.text();
		value = map.get(attrName);
		lo.modifyTime = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.modifyTime));

		attrName = SystemAttribute.F_OID.text();
		if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
			attrName = SystemAttribute.OID + "2";
		}
		value = map.get(attrName);
		lo.fromOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.F_OID.text(), lo.fromOid);

		attrName = SystemAttribute.F_REVISIONOID.text();
		if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
			attrName = SystemAttribute.REVISIONOID + "2";
		}
		value = map.get(attrName);
		lo.fromRevOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.F_REVISIONOID.text(), lo.fromRevOid);

		attrName = SystemAttribute.F_NAMEOID.text();
		value = map.get(attrName);
		lo.fromNameOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromNameOid);

		attrName = SystemAttribute.F_BTWNAME.text();
		value = map.get(attrName);
		lo.fromBTName = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromBTName);

		attrName = SystemAttribute.T_OID.text();
		if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
			attrName = SystemAttribute.OID + "2";
		}
		value = map.get(attrName);
		lo.toOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.T_OID.text(), lo.toOid);

		attrName = SystemAttribute.T_REVISIONOID.text();
		if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
			attrName = SystemAttribute.REVISIONOID + "2";
		}
		value = map.get(attrName);
		lo.toRevOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.T_REVISIONOID.text(), lo.toRevOid);

		attrName = SystemAttribute.T_NAMEOID.text();
		value = map.get(attrName);
		lo.toNameOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toNameOid);

		attrName = SystemAttribute.T_BTWNAME.text();
		value = map.get(attrName);
		lo.toBTName = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toBTName);

		attrName = SystemAttribute.TS.text();
		value = map.get(attrName);
		lo.ts = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.ts));

		// lo自定义属性赋值
		for (String userAttr : ltUserAttrs) {
			attrName = userAttr.toUpperCase();
			value = map.get(attrName);
			loAttrArray[k++] = new AttributeValue(userAttr, getDbRetrunVal(value));
		}

		// 将CONNECT_BY_ISLEAF , LEVEL加入lo.hisAttrValList
		value = map.get("CONNECT_BY_ISLEAF");
		loAttrArray[k++] = new AttributeValue("_ISLEAF", String.valueOf(value == null ? "" : value));

		value = map.get("LEVEL");
		loAttrArray[k++] = new AttributeValue("_LEVEL", String.valueOf(value == null ? "" : value));

		lo.hisAttrValList = loAttrArray;
		lo.newAttrValList = new AttributeValue[0];
		// 目前系统属性没有ltName, 传参赋值
		lo.ltName = ltName;

		// 设置bo
		String btName = null;
		if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
			btName = lo.toBTName;
		} else {
			btName = lo.fromBTName;
		}
		String[] btUserAttrs = null;
		// 优先从缓存中取用户属性
		if (btUserAttrMap.containsKey(btName)) {
			btUserAttrs = btUserAttrMap.get(btName);
		} else {
			//btUserAttrs = ServerServiceProvider.getOMDService().getBTMService().getBtmApNameArray(btName);
			btUserAttrs = OMCacheProvider.getBTAttributes(btName);
			btUserAttrMap.put(btName, btUserAttrs);
		}

		int boAttrSize = btSysAttrSize + btUserAttrs.length;
		AttributeValue[] boAttrArray = new AttributeValue[boAttrSize];
		BusinessObject bo = new BusinessObject();

		// bo系统属性赋值
		k = 0;
		attrName = SystemAttribute.OID.text();
		value = map.get(attrName + "2");
		bo.oid = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.oid);

		attrName = SystemAttribute.REVISIONOID.text();
		value = map.get(attrName + "2");
		bo.revisionid = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.revisionid);

		attrName = SystemAttribute.NAMEOID.text();
		value = map.get(attrName + "2");
		bo.nameoid = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.nameoid);

		attrName = SystemAttribute.BTMNAME.text();
		value = map.get(attrName + "2");
		bo.btName = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.btName);

		attrName = SystemAttribute.ISLASTR.text();
		value = map.get(attrName + "2");
		bo.isLastR = Short.valueOf(String.valueOf(value == null ? "0" : value)) != 0;
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.isLastR));

		attrName = SystemAttribute.ISFIRSTR.text();
		value = map.get(attrName + "2");
		bo.isFirstR = Short.valueOf(String.valueOf(value == null ? "0" : value)) != 0;
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.isFirstR));

		attrName = SystemAttribute.ISLASTV.text();
		value = map.get(attrName + "2");
		bo.isLastV = Short.valueOf(String.valueOf(value == null ? "0" : value)) != 0;
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.isLastV));

		attrName = SystemAttribute.ISFIRSTV.text();
		value = map.get(attrName + "2");
		bo.isFirstV = Short.valueOf(String.valueOf(value == null ? "0" : value)) != 0;
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.isFirstV));

		attrName = SystemAttribute.CREATOR.text();
		value = map.get(attrName + "2");
		bo.creator = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.creator);

		attrName = SystemAttribute.CREATETIME.text();
		value = map.get(attrName + "2");
		bo.createTime = ObjectUtility.getTimeMillis(value);
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.createTime));

		attrName = SystemAttribute.LASTMODIFIER.text();
		value = map.get(attrName + "2");
		bo.modifier = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.modifier);

		attrName = SystemAttribute.LASTMODIFYTIME.text();
		value = map.get(attrName + "2");
		bo.modifyTime = ObjectUtility.getTimeMillis(value);
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.modifyTime));

		attrName = SystemAttribute.REVISIONRULE.text();
		value = map.get(attrName + "2");
		bo.revisionRule = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.revisionRule);

		attrName = SystemAttribute.VERSIONRULE.text();
		value = map.get(attrName + "2");
		bo.versionRule = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.versionRule);

		attrName = SystemAttribute.REVISIONSEQ.text();
		value = map.get(attrName + "2");
		bo.revisionSeq = Short.valueOf(String.valueOf(value == null ? "0" : value));
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.revisionSeq));

		attrName = SystemAttribute.REVISIONVALUE.text();
		value = map.get(attrName + "2");
		bo.revisionValue = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.revisionValue);

		attrName = SystemAttribute.VERSIONSEQ.text();
		value = map.get(attrName + "2");
		bo.versionSeq = Short.valueOf(String.valueOf(value == null ? "0" : value));
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.versionSeq));

		attrName = SystemAttribute.VERSIONVALUE.text();
		value = map.get(attrName + "2");
		bo.versionValue = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.versionValue);

		attrName = SystemAttribute.LCTID.text();
		value = map.get(attrName + "2");
		bo.lctId = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.lctId);

		attrName = SystemAttribute.LCSTATUS.text();
		value = map.get(attrName + "2");
		bo.lcStatus = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.lcStatus);

		attrName = SystemAttribute.TS.text();
		value = map.get(attrName + "2");
		bo.ts = ObjectUtility.getTimeMillis(value);
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.ts));

		attrName = SystemAttribute.ID.text();
		value = map.get(attrName + "2");
		bo.id = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.id);

		attrName = SystemAttribute.NAME.text();
		value = map.get(attrName + "2");
		bo.name = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.name);

		attrName = SystemAttribute.DESCRIPTION.text();
		value = map.get(attrName + "2");
		bo.description = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.description);

		attrName = SystemAttribute.OWNER.text();
		value = map.get(attrName + "2");
		bo.owner = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.owner);

//		attrName = SystemAttribute.CHECKINBY.text();
//		value = map.get(attrName + "2");
//		bo.checkinBy = String.valueOf(value == null ? "" : value);
//		boAttrArray[k++] = new AttributeValue(attrName, bo.checkinBy);
//
//		attrName = SystemAttribute.CHECKINTIME.text();
//		value = map.get(attrName + "2");
//		bo.checkinTime = String.valueOf(value == null ? "" : value);
//		boAttrArray[k++] = new AttributeValue(attrName, bo.checkinTime);
//
//		attrName = SystemAttribute.CHECKOUTBY.text();
//		value = map.get(attrName + "2");
//		bo.checkoutBy = String.valueOf(value == null ? "" : value);
//		boAttrArray[k++] = new AttributeValue(attrName, bo.checkoutBy);
//
//		attrName = SystemAttribute.CHECKOUTTIME.text();
//		value = map.get(attrName + "2");
//		bo.checkoutTime = String.valueOf(value == null ? "" : value);
//		boAttrArray[k++] = new AttributeValue(attrName, bo.checkoutTime);

		attrName = SystemAttribute.COPYFROMVERSION.text();
		value = map.get(attrName + "2");
		bo.fromVersion = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.fromVersion);

		// bo用户属性赋值
		for (String userAttr : btUserAttrs) {
			attrName = userAttr.toUpperCase() + "2";
			value = map.get(attrName);
			boAttrArray[k++] = new AttributeValue(userAttr, getDbRetrunVal(value));
		}
		bo.hisAttrValList = boAttrArray;
		bo.newAttrValList = new AttributeValue[0];

		// 设置boAndLo
		BOAndLO boAndLo = new BOAndLO();
		boAndLo.bo = bo;
		boAndLo.btmName = bo.btName;
		boAndLo.lo = lo;
		boAndLo.ltName = ltName;

		return boAndLo;
	}

	private BOAndLO getBOAndLOOneLevel(Map<String, Object> map, String direction, String[] ltUserAttrs, String ltName,
			int loAttrSize, Map<String, String[]> btUserAttrMap, int btSysAttrSize, Map<String, String> isLeafMap) {
		// 设置lo
		LinkObject lo = new LinkObject();
		AttributeValue[] loAttrArray = new AttributeValue[loAttrSize];
		// 为link的系统属性赋值
		int k = 0;
		String attrName = SystemAttribute.OID.text();
		Object value = map.get(attrName);
		lo.oid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.oid);

		attrName = SystemAttribute.CREATOR.text();
		value = map.get(attrName);
		lo.creator = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.creator);

		attrName = SystemAttribute.CREATETIME.text();
		value = map.get(attrName);
		lo.createTime = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.createTime));

		attrName = SystemAttribute.LASTMODIFIER.text();
		value = map.get(attrName);
		lo.modifier = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.modifier);

		attrName = SystemAttribute.LASTMODIFYTIME.text();
		value = map.get(attrName);
		lo.modifyTime = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.modifyTime));

		attrName = SystemAttribute.F_OID.text();
		if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
			attrName = SystemAttribute.OID + "2";
		}
		value = map.get(attrName);
		lo.fromOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.F_OID.text(), lo.fromOid);

		attrName = SystemAttribute.F_REVISIONOID.text();
		if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
			attrName = SystemAttribute.REVISIONOID + "2";
		}
		value = map.get(attrName);
		lo.fromRevOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.F_REVISIONOID.text(), lo.fromRevOid);

		attrName = SystemAttribute.F_NAMEOID.text();
		value = map.get(attrName);
		lo.fromNameOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromNameOid);

		attrName = SystemAttribute.F_BTWNAME.text();
		value = map.get(attrName);
		lo.fromBTName = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromBTName);

		attrName = SystemAttribute.T_OID.text();
		if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
			attrName = SystemAttribute.OID + "2";
		}
		value = map.get(attrName);
		lo.toOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.T_OID.text(), lo.toOid);

		attrName = SystemAttribute.T_REVISIONOID.text();
		if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
			attrName = SystemAttribute.REVISIONOID + "2";
		}
		value = map.get(attrName);
		lo.toRevOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.T_REVISIONOID.text(), lo.toRevOid);

		attrName = SystemAttribute.T_NAMEOID.text();
		value = map.get(attrName);
		lo.toNameOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toNameOid);

		attrName = SystemAttribute.T_BTWNAME.text();
		value = map.get(attrName);
		lo.toBTName = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toBTName);

		attrName = SystemAttribute.TS.text();
		value = map.get(attrName);
		lo.ts = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.ts));

		// lo自定义属性赋值
		for (String userAttr : ltUserAttrs) {
			attrName = userAttr.toUpperCase();
			value = map.get(attrName);
			loAttrArray[k++] = new AttributeValue(userAttr, getDbRetrunVal(value));
		}

		// 将CONNECT_BY_ISLEAF , LEVEL加入lo.hisAttrValList
		value = isLeafMap.get(lo.oid);
		loAttrArray[k++] = new AttributeValue("_ISLEAF", String.valueOf(value == null ? "" : value));

		value = map.get("LEVEL");
		loAttrArray[k++] = new AttributeValue("_LEVEL", String.valueOf(value == null ? "" : value));

		lo.hisAttrValList = loAttrArray;
		lo.newAttrValList = new AttributeValue[0];
		// 目前系统属性没有ltName, 传参赋值
		lo.ltName = ltName;

		// 设置bo
		String btName = null;
		if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
			btName = lo.toBTName;
		} else {
			btName = lo.fromBTName;
		}
		String[] btUserAttrs = null;
		// 优先从缓存中取用户属性
		if (btUserAttrMap.containsKey(btName)) {
			btUserAttrs = btUserAttrMap.get(btName);
		} else {
			//btUserAttrs = ServerServiceProvider.getOMDService().getBTMService().getBtmApNameArray(btName);
			btUserAttrs = OMCacheProvider.getBTAttributes(btName);
			btUserAttrMap.put(btName, btUserAttrs);
		}

		int boAttrSize = btSysAttrSize + btUserAttrs.length;
		AttributeValue[] boAttrArray = new AttributeValue[boAttrSize];
		BusinessObject bo = new BusinessObject();

		// bo系统属性赋值
		k = 0;
		attrName = SystemAttribute.OID.text();
		value = map.get(attrName + "2");
		bo.oid = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.oid);

		attrName = SystemAttribute.REVISIONOID.text();
		value = map.get(attrName + "2");
		bo.revisionid = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.revisionid);

		attrName = SystemAttribute.NAMEOID.text();
		value = map.get(attrName + "2");
		bo.nameoid = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.nameoid);

		attrName = SystemAttribute.BTMNAME.text();
		value = map.get(attrName + "2");
		bo.btName = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.btName);

		attrName = SystemAttribute.ISLASTR.text();
		value = map.get(attrName + "2");
		bo.isLastR = Short.valueOf(String.valueOf(value == null ? "0" : value)) != 0;
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.isLastR));

		attrName = SystemAttribute.ISFIRSTR.text();
		value = map.get(attrName + "2");
		bo.isFirstR = Short.valueOf(String.valueOf(value == null ? "0" : value)) != 0;
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.isFirstR));

		attrName = SystemAttribute.ISLASTV.text();
		value = map.get(attrName + "2");
		bo.isLastV = Short.valueOf(String.valueOf(value == null ? "0" : value)) != 0;
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.isLastV));

		attrName = SystemAttribute.ISFIRSTV.text();
		value = map.get(attrName + "2");
		bo.isFirstV = Short.valueOf(String.valueOf(value == null ? "0" : value)) != 0;
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.isFirstV));

		attrName = SystemAttribute.CREATOR.text();
		value = map.get(attrName + "2");
		bo.creator = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.creator);

		attrName = SystemAttribute.CREATETIME.text();
		value = map.get(attrName + "2");
		bo.createTime = ObjectUtility.getTimeMillis(value);
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.createTime));

		attrName = SystemAttribute.LASTMODIFIER.text();
		value = map.get(attrName + "2");
		bo.modifier = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.modifier);

		attrName = SystemAttribute.LASTMODIFYTIME.text();
		value = map.get(attrName + "2");
		bo.modifyTime = ObjectUtility.getTimeMillis(value);
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.modifyTime));

		attrName = SystemAttribute.REVISIONRULE.text();
		value = map.get(attrName + "2");
		bo.revisionRule = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.revisionRule);

		attrName = SystemAttribute.VERSIONRULE.text();
		value = map.get(attrName + "2");
		bo.versionRule = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.versionRule);

		attrName = SystemAttribute.REVISIONSEQ.text();
		value = map.get(attrName + "2");
		bo.revisionSeq = Short.valueOf(String.valueOf(value == null ? "0" : value));
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.revisionSeq));

		attrName = SystemAttribute.REVISIONVALUE.text();
		value = map.get(attrName + "2");
		bo.revisionValue = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.revisionValue);

		attrName = SystemAttribute.VERSIONSEQ.text();
		value = map.get(attrName + "2");
		bo.versionSeq = Short.valueOf(String.valueOf(value == null ? "0" : value));
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.versionSeq));

		attrName = SystemAttribute.VERSIONVALUE.text();
		value = map.get(attrName + "2");
		bo.versionValue = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.versionValue);

		attrName = SystemAttribute.LCTID.text();
		value = map.get(attrName + "2");
		bo.lctId = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.lctId);

		attrName = SystemAttribute.LCSTATUS.text();
		value = map.get(attrName + "2");
		bo.lcStatus = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.lcStatus);

		attrName = SystemAttribute.TS.text();
		value = map.get(attrName + "2");
		bo.ts = ObjectUtility.getTimeMillis(value);
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.ts));

		attrName = SystemAttribute.ID.text();
		value = map.get(attrName + "2");
		bo.id = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.id);

		attrName = SystemAttribute.NAME.text();
		value = map.get(attrName + "2");
		bo.name = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.name);

		attrName = SystemAttribute.DESCRIPTION.text();
		value = map.get(attrName + "2");
		bo.description = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.description);

		attrName = SystemAttribute.OWNER.text();
		value = map.get(attrName + "2");
		bo.owner = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.owner);

//		attrName = SystemAttribute.CHECKINBY.text();
//		value = map.get(attrName + "2");
//		bo.checkinBy = String.valueOf(value == null ? "" : value);
//		boAttrArray[k++] = new AttributeValue(attrName, bo.checkinBy);
//
//		attrName = SystemAttribute.CHECKINTIME.text();
//		value = map.get(attrName + "2");
//		bo.checkinTime = String.valueOf(value == null ? "" : value);
//		boAttrArray[k++] = new AttributeValue(attrName, bo.checkinTime);
//
//		attrName = SystemAttribute.CHECKOUTBY.text();
//		value = map.get(attrName + "2");
//		bo.checkoutBy = String.valueOf(value == null ? "" : value);
//		boAttrArray[k++] = new AttributeValue(attrName, bo.checkoutBy);
//
//		attrName = SystemAttribute.CHECKOUTTIME.text();
//		value = map.get(attrName + "2");
//		bo.checkoutTime = String.valueOf(value == null ? "" : value);
//		boAttrArray[k++] = new AttributeValue(attrName, bo.checkoutTime);

		attrName = SystemAttribute.COPYFROMVERSION.text();
		value = map.get(attrName + "2");
		bo.fromVersion = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.fromVersion);

		// bo用户属性赋值
		for (String userAttr : btUserAttrs) {
			attrName = userAttr.toUpperCase() + "2";
			value = map.get(attrName);
			boAttrArray[k++] = new AttributeValue(userAttr, getDbRetrunVal(value));
		}
		bo.hisAttrValList = boAttrArray;
		bo.newAttrValList = new AttributeValue[0];

		// 设置boAndLo
		BOAndLO boAndLo = new BOAndLO();
		boAndLo.bo = bo;
		boAndLo.btmName = bo.btName;
		boAndLo.lo = lo;
		boAndLo.ltName = ltName;

		return boAndLo;
	}

	/**
	 * 将数据库返回值转换为字符串，主要处理clob类型字段
	 * 
	 * @param value
	 * @return
	 */
	public String getDbRetrunVal(Object value) {
		String attrVal = "";
		if (value instanceof Clob) {
			attrVal = String.valueOf(value == null ? "" : clobToString((Clob) value));
		} else {
			attrVal = String.valueOf(value == null ? "" : value);
		}

		return attrVal;
	}
}

/**
 * GetBOAndLO Callable
 * 
 * @author zhouhui
 *
 */
class QueryBOAndLO implements Callable<BOAndLO> {
	private Map<String, Object> map;
	private String direction;
	private String[] ltUserAttrs;
	private String ltName;
	private int loAttrSize;
	private Map<String, String[]> btUserAttrMap;
	private int btSysAttrSize;

	/**
	 * 将一条查询出的记录封装成BOAndLO
	 * 
	 * @param map:           一条从linkTable和btmView查询出的记录
	 * @param direction:     链接查询的方向
	 * @param ltUserAttrs:   链接类型的用户属性
	 * @param ltName:        链接类型
	 * @param loAttrSize:    链接类型的属性长度(系统属性+用户属性)
	 * @param btUserAttrMap: 业务类型及其对应的用户属性Map
	 * @param btSysAttrSize: 业务类型的系统属性长度
	 * @param map
	 * @param direction
	 * @param ltUserAttrs
	 * @param ltName
	 * @param loAttrSize
	 * @param btUserAttrMap
	 * @param btSysAttrSize
	 */
	public QueryBOAndLO(Map<String, Object> map, String direction, String[] ltUserAttrs, String ltName, int loAttrSize,
			Map<String, String[]> btUserAttrMap, int btSysAttrSize) {
		this.map = map;
		this.direction = direction;
		this.ltUserAttrs = ltUserAttrs;
		this.ltName = ltName;
		this.loAttrSize = loAttrSize;
		this.btUserAttrMap = btUserAttrMap;
		this.btSysAttrSize = btSysAttrSize;
	}

	@Override
	public BOAndLO call() throws Exception {
		Thread.currentThread().setName("bolocall");
		// 设置lo
		LinkObject lo = new LinkObject();
		AttributeValue[] loAttrArray = new AttributeValue[loAttrSize];
		// 为link的系统属性赋值
		int k = 0;
		String attrName = SystemAttribute.OID.text();
		Object value = map.get(attrName);
		lo.oid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.oid);

		attrName = SystemAttribute.CREATOR.text();
		value = map.get(attrName);
		lo.creator = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.creator);

		attrName = SystemAttribute.CREATETIME.text();
		value = map.get(attrName);
		lo.createTime = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.createTime));

		attrName = SystemAttribute.LASTMODIFIER.text();
		value = map.get(attrName);
		lo.modifier = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.modifier);

		attrName = SystemAttribute.LASTMODIFYTIME.text();
		value = map.get(attrName);
		lo.modifyTime = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.modifyTime));

		attrName = SystemAttribute.F_OID.text();
		if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
			attrName = SystemAttribute.OID + "2";
		}
		value = map.get(attrName);
		lo.fromOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.F_OID.text(), lo.fromOid);

		attrName = SystemAttribute.F_REVISIONOID.text();
		if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
			attrName = SystemAttribute.REVISIONOID + "2";
		}
		value = map.get(attrName);
		lo.fromRevOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.F_REVISIONOID.text(), lo.fromRevOid);

		attrName = SystemAttribute.F_NAMEOID.text();
		value = map.get(attrName);
		lo.fromNameOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromNameOid);

		attrName = SystemAttribute.F_BTWNAME.text();
		value = map.get(attrName);
		lo.fromBTName = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.fromBTName);

		attrName = SystemAttribute.T_OID.text();
		if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
			attrName = SystemAttribute.OID + "2";
		}
		value = map.get(attrName);
		lo.toOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.T_OID.text(), lo.toOid);

		attrName = SystemAttribute.T_REVISIONOID.text();
		if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
			attrName = SystemAttribute.REVISIONOID + "2";
		}
		value = map.get(attrName);
		lo.toRevOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(SystemAttribute.T_REVISIONOID.text(), lo.toRevOid);

		attrName = SystemAttribute.T_NAMEOID.text();
		value = map.get(attrName);
		lo.toNameOid = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toNameOid);

		attrName = SystemAttribute.T_BTWNAME.text();
		value = map.get(attrName);
		lo.toBTName = String.valueOf(value == null ? "" : value);
		loAttrArray[k++] = new AttributeValue(attrName, lo.toBTName);

		attrName = SystemAttribute.TS.text();
		value = map.get(attrName);
		lo.ts = ObjectUtility.getTimeMillis(value);
		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.ts));

		// lo自定义属性赋值
		for (String userAttr : ltUserAttrs) {
			attrName = userAttr.toUpperCase();
			value = map.get(attrName);
			loAttrArray[k++] = new AttributeValue(userAttr, QueryObjectService.getInstance().getDbRetrunVal(value));
		}

		// 将CONNECT_BY_ISLEAF , LEVEL加入lo.hisAttrValList
		value = map.get("CONNECT_BY_ISLEAF");
		loAttrArray[k++] = new AttributeValue("_ISLEAF", String.valueOf(value == null ? "" : value));

		value = map.get("LEVEL");
		loAttrArray[k++] = new AttributeValue("_LEVEL", String.valueOf(value == null ? "" : value));

		lo.hisAttrValList = loAttrArray;
		lo.newAttrValList = new AttributeValue[0];
		// 目前系统属性没有ltName, 传参赋值
		lo.ltName = ltName;

		// 设置bo
		String btName = null;
		if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
			btName = lo.toBTName;
		} else {
			btName = lo.fromBTName;
		}
		String[] btUserAttrs = null;
		// 优先从缓存中取用户属性
		if (btUserAttrMap.containsKey(btName)) {
			btUserAttrs = btUserAttrMap.get(btName);
		} else {
			btUserAttrs = OMCacheProvider.getBTAttributes(btName);// BtmProvider.getInstance().getAbNames(btName);
			btUserAttrMap.put(btName, btUserAttrs);
		}

		int boAttrSize = btSysAttrSize + btUserAttrs.length;
		AttributeValue[] boAttrArray = new AttributeValue[boAttrSize];
		BusinessObject bo = new BusinessObject();

		// bo系统属性赋值
		k = 0;
		attrName = SystemAttribute.OID.text();
		value = map.get(attrName + "2");
		bo.oid = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.oid);

		attrName = SystemAttribute.REVISIONOID.text();
		value = map.get(attrName + "2");
		bo.revisionid = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.revisionid);

		attrName = SystemAttribute.NAMEOID.text();
		value = map.get(attrName + "2");
		bo.nameoid = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.nameoid);

		attrName = SystemAttribute.BTMNAME.text();
		value = map.get(attrName + "2");
		bo.btName = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.btName);

		attrName = SystemAttribute.ISLASTR.text();
		value = map.get(attrName + "2");
		bo.isLastR = Short.valueOf(String.valueOf(value == null ? "0" : value)) != 0;
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.isLastR));

		attrName = SystemAttribute.ISFIRSTR.text();
		value = map.get(attrName + "2");
		bo.isFirstR = Short.valueOf(String.valueOf(value == null ? "0" : value)) != 0;
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.isFirstR));

		attrName = SystemAttribute.ISLASTV.text();
		value = map.get(attrName + "2");
		bo.isLastV = Short.valueOf(String.valueOf(value == null ? "0" : value)) != 0;
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.isLastV));

		attrName = SystemAttribute.ISFIRSTV.text();
		value = map.get(attrName + "2");
		bo.isFirstV = Short.valueOf(String.valueOf(value == null ? "0" : value)) != 0;
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.isFirstV));

		attrName = SystemAttribute.CREATOR.text();
		value = map.get(attrName + "2");
		bo.creator = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.creator);

		attrName = SystemAttribute.CREATETIME.text();
		value = map.get(attrName + "2");
		bo.createTime = ObjectUtility.getTimeMillis(value);
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.createTime));

		attrName = SystemAttribute.LASTMODIFIER.text();
		value = map.get(attrName + "2");
		bo.modifier = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.modifier);

		attrName = SystemAttribute.LASTMODIFYTIME.text();
		value = map.get(attrName + "2");
		bo.modifyTime = ObjectUtility.getTimeMillis(value);
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.modifyTime));

		attrName = SystemAttribute.REVISIONRULE.text();
		value = map.get(attrName + "2");
		bo.revisionRule = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.revisionRule);

		attrName = SystemAttribute.VERSIONRULE.text();
		value = map.get(attrName + "2");
		bo.versionRule = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.versionRule);

		attrName = SystemAttribute.REVISIONSEQ.text();
		value = map.get(attrName + "2");
		bo.revisionSeq = Short.valueOf(String.valueOf(value == null ? "0" : value));
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.revisionSeq));

		attrName = SystemAttribute.REVISIONVALUE.text();
		value = map.get(attrName + "2");
		bo.revisionValue = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.revisionValue);

		attrName = SystemAttribute.VERSIONSEQ.text();
		value = map.get(attrName + "2");
		bo.versionSeq = Short.valueOf(String.valueOf(value == null ? "0" : value));
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.versionSeq));

		attrName = SystemAttribute.VERSIONVALUE.text();
		value = map.get(attrName + "2");
		bo.versionValue = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.versionValue);

		attrName = SystemAttribute.LCTID.text();
		value = map.get(attrName + "2");
		bo.lctId = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.lctId);

		attrName = SystemAttribute.LCSTATUS.text();
		value = map.get(attrName + "2");
		bo.lcStatus = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.lcStatus);

		attrName = SystemAttribute.TS.text();
		value = map.get(attrName + "2");
		bo.ts = ObjectUtility.getTimeMillis(value);
		boAttrArray[k++] = new AttributeValue(attrName, String.valueOf(bo.ts));

		attrName = SystemAttribute.ID.text();
		value = map.get(attrName + "2");
		bo.id = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.id);

		attrName = SystemAttribute.NAME.text();
		value = map.get(attrName + "2");
		bo.name = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.name);

		attrName = SystemAttribute.DESCRIPTION.text();
		value = map.get(attrName + "2");
		bo.description = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.description);

		attrName = SystemAttribute.OWNER.text();
		value = map.get(attrName + "2");
		bo.owner = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.owner);

//		attrName = SystemAttribute.CHECKINBY.text();
//		value = map.get(attrName + "2");
//		bo.checkinBy = String.valueOf(value == null ? "" : value);
//		boAttrArray[k++] = new AttributeValue(attrName, bo.checkinBy);
//
//		attrName = SystemAttribute.CHECKINTIME.text();
//		value = map.get(attrName + "2");
//		bo.checkinTime = String.valueOf(value == null ? "" : value);
//		boAttrArray[k++] = new AttributeValue(attrName, bo.checkinTime);
//
//		attrName = SystemAttribute.CHECKOUTBY.text();
//		value = map.get(attrName + "2");
//		bo.checkoutBy = String.valueOf(value == null ? "" : value);
//		boAttrArray[k++] = new AttributeValue(attrName, bo.checkoutBy);
//
//		attrName = SystemAttribute.CHECKOUTTIME.text();
//		value = map.get(attrName + "2");
//		bo.checkoutTime = String.valueOf(value == null ? "" : value);
//		boAttrArray[k++] = new AttributeValue(attrName, bo.checkoutTime);

		attrName = SystemAttribute.COPYFROMVERSION.text();
		value = map.get(attrName + "2");
		bo.fromVersion = String.valueOf(value == null ? "" : value);
		boAttrArray[k++] = new AttributeValue(attrName, bo.fromVersion);

		// bo用户属性赋值
		for (String userAttr : btUserAttrs) {
			attrName = userAttr.toUpperCase() + "2";
			value = map.get(attrName);
			boAttrArray[k++] = new AttributeValue(userAttr, QueryObjectService.getInstance().getDbRetrunVal(value));
		}
		bo.hisAttrValList = boAttrArray;
		bo.newAttrValList = new AttributeValue[0];

		// 设置boAndLo
		BOAndLO boAndLo = new BOAndLO();
		boAndLo.bo = bo;
		boAndLo.btmName = bo.btName;
		boAndLo.lo = lo;
		boAndLo.ltName = ltName;

		return boAndLo;
	}
}

class QueryLOWithVersion implements Callable<LinkObject> {
	private Map<String, Object> map;
	private String direction;
	private String[] ltUserAttrs;
	private String ltName;
	private int loAttrSize;
	private List<String> clauseList;

	/**
	 * 
	 * 将一条查询出的记录封装成LO, 用btmView.OID, btmView.REVISIONOID作t_oid, t_revisionOid
	 * 
	 * @param map:         一条从linkTable和btmView.OID, btmView.REVISIONOID查询出的记录
	 * @param direction:   链接查询的方向
	 * @param ltUserAttrs: 链接类型的用户属性
	 * @param ltName:      链接类型
	 * @param loAttrSize:  链接类型的属性长度(系统属性+用户属性)
	 */
	public QueryLOWithVersion(Map<String, Object> map, String direction, String[] ltUserAttrs, String ltName,
			int loAttrSize) {
		this.map = map;
		this.direction = direction;
		this.ltUserAttrs = ltUserAttrs;
		this.ltName = ltName;
		this.loAttrSize = loAttrSize;
	}

	/**
	 * 
	 * 将一条查询出的记录封装成LO, 用btmView.OID, btmView.REVISIONOID作t_oid, t_revisionOid
	 * 
	 * @param map:         一条从linkTable和btmView.OID, btmView.REVISIONOID查询出的记录
	 * @param direction:   链接查询的方向
	 * @param ltUserAttrs: 链接类型的用户属性
	 * @param ltName:      链接类型
	 * @param loAttrSize:  链接类型的属性长度(系统属性+用户属性)
	 * @param clauseList   返回列
	 */
	public QueryLOWithVersion(Map<String, Object> map, String direction, String[] ltUserAttrs, String ltName,
			int loAttrSize, List<String> clauseList) {
		this.map = map;
		this.direction = direction;
		this.ltUserAttrs = ltUserAttrs;
		this.ltName = ltName;
		this.loAttrSize = loAttrSize;
		this.clauseList = clauseList;
	}

	@Override
	public LinkObject call() throws Exception {
		// 设置lo
		LinkObject lo = new LinkObject();
		// 为link的系统属性赋值
		List<AttributeValue> attrList = new ArrayList<AttributeValue>();
		AttributeValue[] loAttrArrayNew = new AttributeValue[clauseList.size()];
		for (int i = 0; i < clauseList.size(); i++) {
			String attrName = clauseList.get(i).toUpperCase();
			if (attrName.indexOf(" AS ") > -1) {
				attrName = attrName.substring(attrName.lastIndexOf(" AS ") + 4);
			}
			Object attrVal = map.get(attrName);
			if (attrName.equalsIgnoreCase(SystemAttribute.F_OID.text())) {
				if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
					attrName = SystemAttribute.OID + "2";
				}
				attrVal = map.get(attrName);
				attrName = SystemAttribute.F_OID.text();
			} else if (attrName.equalsIgnoreCase(SystemAttribute.F_REVISIONOID.text())) {
				if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
					attrName = SystemAttribute.REVISIONOID + "2";
				}
				attrVal = map.get(attrName);
				attrName = SystemAttribute.F_REVISIONOID.text();
			} else if (attrName.equalsIgnoreCase(SystemAttribute.T_OID.text())) {
				if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
					attrName = SystemAttribute.OID + "2";
				}
				attrVal = map.get(attrName);
				attrName = SystemAttribute.T_OID.text();
			} else if (attrName.equalsIgnoreCase(SystemAttribute.T_REVISIONOID.text())) {
				if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
					attrName = SystemAttribute.REVISIONOID + "2";
				}
				attrVal = map.get(attrName);
				attrName = SystemAttribute.T_REVISIONOID.text();
			}

			if (!attrName.equals(SystemAttribute.REVISIONOID + "2") && !attrName.equals(SystemAttribute.OID + "2")) {
				String attrValStr = String.valueOf(attrVal == null ? "" : attrVal);
				attrList.add(new AttributeValue(attrName, attrValStr));
			}
		}
		String attrName = SystemAttribute.OID.text();
		Object value = map.get(attrName);
		lo.oid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.CREATOR.text();
		value = map.get(attrName);
		lo.creator = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.CREATETIME.text();
		value = map.get(attrName);
		lo.createTime = ObjectUtility.getTimeMillis(value);

		attrName = SystemAttribute.LASTMODIFIER.text();
		value = map.get(attrName);
		lo.modifier = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.LASTMODIFYTIME.text();
		value = map.get(attrName);
		lo.modifyTime = ObjectUtility.getTimeMillis(value);

		attrName = SystemAttribute.F_OID.text();
		if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
			attrName = SystemAttribute.OID + "2";
		}
		value = map.get(attrName);
		lo.fromOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.F_REVISIONOID.text();
		if (direction.equals(QTConstants.DIRECTION_OPPOSITE)) {
			attrName = SystemAttribute.REVISIONOID + "2";
		}
		value = map.get(attrName);
		lo.fromRevOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.F_NAMEOID.text();
		value = map.get(attrName);
		lo.fromNameOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.F_BTWNAME.text();
		value = map.get(attrName);
		lo.fromBTName = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.T_OID.text();
		if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
			attrName = SystemAttribute.OID + "2";
		}
		value = map.get(attrName);
		lo.toOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.T_REVISIONOID.text();
		if (direction.equals(QTConstants.DIRECTION_POSITIVE)) {
			attrName = SystemAttribute.REVISIONOID + "2";
		}
		value = map.get(attrName);
		lo.toRevOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.T_NAMEOID.text();
		value = map.get(attrName);
		lo.toNameOid = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.T_BTWNAME.text();
		value = map.get(attrName);
		lo.toBTName = String.valueOf(value == null ? "" : value);

		attrName = SystemAttribute.TS.text();
		value = map.get(attrName);
		lo.ts = ObjectUtility.getTimeMillis(value);

		// 将CONNECT_BY_ISLEAF , LEVEL加入lo.hisAttrValList
		value = map.get("CONNECT_BY_ISLEAF");
		attrList.add(new AttributeValue("_ISLEAF", String.valueOf(value == null ? "" : value)));

		value = map.get("LEVEL");
		attrList.add(new AttributeValue("_LEVEL", String.valueOf(value == null ? "" : value)));

		loAttrArrayNew = attrList.toArray(new AttributeValue[0]);
		lo.hisAttrValList = loAttrArrayNew;
		lo.newAttrValList = new AttributeValue[0];
		// 目前系统属性没有ltName, 传参赋值
		lo.ltName = ltName;
		return lo;
	}

//	@Override
//	public LinkObject call() throws Exception {
//		//设置lo
//		LinkObject lo = new LinkObject();
//		AttributeValue[] loAttrArray = new AttributeValue[loAttrSize];
//		//为link的系统属性赋值
//		int k = 0;
//		String attrName = SystemAttribute.OID.text();
//		Object value = map.get(attrName);
//		lo.oid = String.valueOf(value == null ? "" : value);
//		loAttrArray[k++] = new AttributeValue(attrName, lo.oid);
//		
//		attrName = SystemAttribute.CREATOR.text();
//		value = map.get(attrName);
//		lo.creator = String.valueOf(value == null ? "" : value);
//		loAttrArray[k++] = new AttributeValue(attrName, lo.creator);
//		
//		attrName = SystemAttribute.CREATETIME.text();
//		value = map.get(attrName);
//		lo.createTime = String.valueOf(value == null ? "" : value);
//		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.createTime));
//		
//		attrName = SystemAttribute.LASTMODIFIER.text();
//		value = map.get(attrName);
//		lo.lastModifier = String.valueOf(value == null ? "" : value);
//		loAttrArray[k++] = new AttributeValue(attrName, lo.lastModifier);
//		
//		attrName = SystemAttribute.LASTMODIFYTIME.text();
//		value = map.get(attrName);
//		lo.lastModifyTime = String.valueOf(value == null ? "" : value);
//		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.lastModifyTime));
//		
//		attrName = SystemAttribute.F_OID.text();
//		if(direction.equals(QTConstants.DIRECTION_OPPOSITE)){
//			attrName = SystemAttribute.OID + "2";
//		}
//		value = map.get(attrName);
//		lo.fromOid = String.valueOf(value == null ? "" : value);
//		loAttrArray[k++] = new AttributeValue(SystemAttribute.F_OID.text(), lo.fromOid);
//		
//		attrName = SystemAttribute.F_REVISIONOID.text();
//		if(direction.equals(QTConstants.DIRECTION_OPPOSITE)){
//			attrName = SystemAttribute.REVISIONOID + "2";
//		}
//		value = map.get(attrName);
//		lo.fromRevisionOid = String.valueOf(value == null ? "" : value);
//		loAttrArray[k++] = new AttributeValue(SystemAttribute.F_REVISIONOID.text(), lo.fromRevisionOid);
//		
//		attrName = SystemAttribute.F_NAMEOID.text();
//		value = map.get(attrName);
//		lo.fromNameOid = String.valueOf(value == null ? "" : value);
//		loAttrArray[k++] = new AttributeValue(attrName, lo.fromNameOid);
//		
//		attrName = SystemAttribute.F_BTWNAME.text();
//		value = map.get(attrName);
//		lo.fromBTMName = String.valueOf(value == null ? "" : value);
//		loAttrArray[k++] = new AttributeValue(attrName, lo.fromBTMName);
//		
//		attrName = SystemAttribute.T_OID.text();
//		if(direction.equals(QTConstants.DIRECTION_POSITIVE)){
//			attrName = SystemAttribute.OID + "2";
//		}
//		value = map.get(attrName);
//		lo.toOid = String.valueOf(value == null ? "" : value);
//		loAttrArray[k++] = new AttributeValue(SystemAttribute.T_OID.text(), lo.toOid);
//		
//		attrName = SystemAttribute.T_REVISIONOID.text();
//		if(direction.equals(QTConstants.DIRECTION_POSITIVE)){
//			attrName = SystemAttribute.REVISIONOID + "2";
//		}
//		value = map.get(attrName);
//		lo.toRevisionOid = String.valueOf(value == null ? "" : value);
//		loAttrArray[k++] = new AttributeValue(SystemAttribute.T_REVISIONOID.text(), lo.toRevisionOid);
//		
//		attrName = SystemAttribute.T_NAMEOID.text();
//		value = map.get(attrName);
//		lo.toNameOid = String.valueOf(value == null ? "" : value);
//		loAttrArray[k++] = new AttributeValue(attrName, lo.toNameOid);
//		
//		attrName = SystemAttribute.T_BTWNAME.text();
//		value = map.get(attrName);
//		lo.toBTMName = String.valueOf(value == null ? "" : value);
//		loAttrArray[k++] = new AttributeValue(attrName, lo.toBTMName);
//		
//		attrName = SystemAttribute.TS.text();
//		value = map.get(attrName);
//		lo.ts = String.valueOf(value == null ? "" : value);
//		loAttrArray[k++] = new AttributeValue(attrName, String.valueOf(lo.ts));
//		
//		//lo自定义属性赋值
//		for(String userAttr : ltUserAttrs){
//			attrName = userAttr.toUpperCase();
//			value = map.get(attrName);
//			loAttrArray[k++] = new AttributeValue(userAttr, String.valueOf(value == null ? "" : value));
//		}
//		
//		//将CONNECT_BY_ISLEAF , LEVEL加入lo.hisAttrValList
//		value = map.get("CONNECT_BY_ISLEAF");
//		loAttrArray[k++] = new AttributeValue("_ISLEAF", String.valueOf(value == null ? "" : value));
//		
//		value = map.get("LEVEL");
//		loAttrArray[k++] = new AttributeValue("_LEVEL", String.valueOf(value == null ? "" : value));
//		
//		lo.hisAttrValList = loAttrArray;
//		lo.newAttrValList = new AttributeValue[0];
//		//目前系统属性没有ltName, 传参赋值
//		lo.linkTypeName = ltName;		
//		return lo;		
//	}

}