package com.vci.server.bof.service;

import java.math.BigDecimal;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import org.apache.commons.lang3.StringUtils;
import org.hibernate.SQLQuery;
import org.hibernate.Session;

import com.vci.omd.constants.LinkConstants;
import com.vci.server.base.persistence.dao.HibernateSessionFactory;
import com.vci.server.base.utility.OmdHelper;
import com.vci.server.bof.objects.LinkTypeWrap;
import com.vci.server.cache.OMCacheProvider;
import com.vci.corba.common.VCIError;
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.common.log.ServerWithLog4j;
import com.vci.common.utility.ObjectUtility;

public class LOFactoryService extends BOFactoryBaseService {

	private int BATCHSIZE = 2000;

	private static LOFactoryService instance = null;

	private LOFactoryService() {

	}

	public static synchronized LOFactoryService getInstance() {
		if (instance == null) {
			instance = new LOFactoryService();
		}

		return instance;
	}

	/**
	 * 创建新对象
	 * 
	 * @param lo
	 * @return
	 * @throws Throwable
	 * @throws Exception
	 */
	public LinkObject createLinkObject(LinkObject lo) throws Exception, Throwable {
		String tableName = OmdHelper.getLTTableName(lo.ltName);

		// Jason。wang 取消通过cobra服务获取LinkType的对象定义信息，直接使用服务器端服务的方式获取。
		//LinkType linkType = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(lo.linkTypeName);
		LinkType linkType = OMCacheProvider.getLinkType(lo.ltName);
		// end Jason.Wang 2018.6.28

		int count = 0;

		if (linkType.relationFrom.equals("1") && linkType.relationTo.equals("N")) {
			count = getLinkObjectCountByFromTOObject(lo.fromOid, lo.toOid, tableName, 2);
		} else if (linkType.relationFrom.equals("N") && linkType.relationTo.equals("1")) {
			count = getLinkObjectCountByFromTOObject(lo.fromOid, lo.toOid, tableName, 3);
		} else if (linkType.relationFrom.equals("1") && linkType.relationTo.equals("1")) {
			count = getLinkObjectCountByFromTOObject(lo.fromOid, lo.toOid, tableName, 1);
		}

		if (count > 0) {
			throw new VCIError("P0010LOL-00005", new String[] { linkType.relationFrom, linkType.relationTo });
		}

		//AttribItem[] items = ServerServiceProvider.getOMDService().getAttributeService().getAttribItemsByNames(linkType.attributes);
		AttribItem[] items = OMCacheProvider.getAttributes(linkType.attributes);
		Map<String, AttribItem> attrItemMap = new HashMap<String, AttribItem>();
		for (int i = 0; i < items.length; i++) {
			attrItemMap.put(items[i].name, items[i]);
		}

		// Map<String, AttribItem> attrItemMap = getLOAttributeItemMap(lo.linkTypeName);
		String sql = getCreateLOSql(lo, tableName, attrItemMap);
		Session session = HibernateSessionFactory.getSession();

		SQLQuery query = session.createSQLQuery(sql);
		prepareCreateLOPsmt(query, lo, attrItemMap);
		query.executeUpdate();

		return lo;
	}

	private LinkObject createLinkObject(LinkObject lo, LinkType linkType, Map<String, AttribItem> attrItemMap)
			throws Exception, Throwable {
		String tableName = OmdHelper.getLTTableName(lo.ltName);

		int count = 0;

		if (linkType.relationFrom.equals("1") && linkType.relationTo.equals("N")) {
			count = getLinkObjectCountByFromTOObject(lo.fromOid, lo.toOid, tableName, 2);
		} else if (linkType.relationFrom.equals("N") && linkType.relationTo.equals("1")) {
			count = getLinkObjectCountByFromTOObject(lo.fromOid, lo.toOid, tableName, 3);
		} else if (linkType.relationFrom.equals("1") && linkType.relationTo.equals("1")) {
			count = getLinkObjectCountByFromTOObject(lo.fromOid, lo.toOid, tableName, 1);
		}

		if (count > 0) {
			throw new VCIError("P0010LOL-00005", new String[] { linkType.relationFrom, linkType.relationTo });
		}

		String sql = getCreateLOSql(lo, tableName, attrItemMap);
		Session session = HibernateSessionFactory.getSession();

		SQLQuery query = session.createSQLQuery(sql);
		prepareCreateLOPsmt(query, lo, attrItemMap);
		query.executeUpdate();

		return lo;
	}

	/**
	 * 根据from、to端的类型获取已经建立类型的关系数
	 * 
	 * @param fromType
	 * @param toType
	 * @param linkType
	 * @return
	 * @throws SQLException
	 */
	@SuppressWarnings("rawtypes")
	private int getLinkObjectCountByFromTOObject(String fromOid, String toOid, String tableName, int type)
			throws SQLException {

		String sql = "";
		if (type == 1) {
			sql = getSelectLOOneOneCountSql(fromOid, toOid, tableName);
		} else if (type == 2) {
			sql = getSelectLOOneManyCountSql(fromOid, toOid, tableName);
		} else if (type == 3) {
			sql = getSelectLOManyOneCountSql(fromOid, toOid, tableName);
		}

		Session session = HibernateSessionFactory.getSession();

		SQLQuery query = session.createSQLQuery(sql);
		List queryList = query.list();
		Object array = (Object) queryList.get(0);
		int count = ((BigDecimal) array).intValue();

		return count;
	}

	/**
	 * 获取关系为一对一时查询关系数据的SQL语句
	 * 
	 * @param fromOid
	 * @param toOid
	 * @param tableName
	 * @return
	 */
	private String getSelectLOOneOneCountSql(String fromOid, String toOid, String tableName) {
		String sql = "";
		StringBuffer sbFields = new StringBuffer("SELECT count(*) FROM ").append(tableName)
				.append(" p where p.F_OID = '").append(fromOid).append("'").append(" or p.T_OID = '").append(toOid)
				.append("'");
		sql = sbFields.toString();
		return sql;
	}

	/**
	 * 获取关系为一对多时查询关系数据的sql语句
	 * 
	 * @param fromOid
	 * @param toOid
	 * @param tableName
	 * @return
	 */
	private String getSelectLOOneManyCountSql(String fromOid, String toOid, String tableName) {
		String sql = "";
		StringBuffer sbFields = new StringBuffer("SELECT count(*) FROM ").append(tableName)
				.append(" p where p.T_OID = '").append(toOid).append("'");
		sql = sbFields.toString();
		return sql;
	}

	/**
	 * 获取关系为多对一时查询关系数据的sql语句
	 * 
	 * @param fromOid
	 * @param toOid
	 * @param tableName
	 * @return
	 */
	private String getSelectLOManyOneCountSql(String fromOid, String toOid, String tableName) {
		String sql = "";
		StringBuffer sbFields = new StringBuffer("SELECT count(*) FROM ").append(tableName)
				.append(" p where p.F_OID = '").append(fromOid).append("'");
		sql = sbFields.toString();
		return sql;
	}

	/**
	 * 根据from、to端的类型获取已经建立类型的关系数的sql。
	 * 
	 * @param fromType
	 * @param toType
	 * @param tableName
	 * @return
	 */
	@SuppressWarnings("unused")
	private String getSelectLOCountSql(String fromType, String toType, String tableName) {
		String sql = "";
		StringBuffer sbFields = new StringBuffer("SELECT count(*) FROM ").append(tableName)
				.append(" p where p.F_BTWNAME = '").append(fromType).append("'").append(" and p.T_BTWNAME = '")
				.append(toType).append("'");
		sql = sbFields.toString();
		return sql;
	}

	@SuppressWarnings("deprecation")
	public LinkObject[] batchCreateLinkObjectNoCheck(LinkObject[] los, String currentTime)
			throws Exception {
		Map<String, List<LinkObject>> mapLtLOs = new HashMap<String, List<LinkObject>>();
		List<LinkObject> lstLO = null;

		Map<String, LinkTypeWrap> mapLTWrap = new HashMap<String, LinkTypeWrap>();
		LinkTypeWrap ltWrap = null;

		String sql;

		for (LinkObject lo : los) {

			if (mapLTWrap.containsKey(lo.ltName)) {
				ltWrap = mapLTWrap.get(lo.ltName);
			} else {
				ltWrap = new LinkTypeWrap();
				//ltWrap.ltItem = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(lo.linkTypeName);
				ltWrap.ltItem = OMCacheProvider.getLinkType(lo.ltName);
				mapLTWrap.put(lo.ltName, ltWrap);
			}

			if (ltWrap.mapAttr == null) {
				//AttribItem[] items = ServerServiceProvider.getOMDService().getAttributeService().getAttribItemsByNames(ltWrap.ltItem.attributes);
				AttribItem[] items = OMCacheProvider.getAttributes(ltWrap.ltItem.attributes);
				Map<String, AttribItem> attrMap = new HashMap<String, AttribItem>();
				for (int i = 0; i < items.length; i++) {
					attrMap.put(items[i].name, items[i]);
				}
				ltWrap.mapAttr = attrMap;
			}

			if (ltWrap.tableName == null) {
				ltWrap.tableName = OmdHelper.getLTTableName(lo.ltName);
			}

			if (mapLtLOs.containsKey(lo.ltName))
				lstLO = mapLtLOs.get(lo.ltName);
			else {
				lstLO = new ArrayList<LinkObject>();
				mapLtLOs.put(lo.ltName, lstLO);
			}

			lstLO.add(lo);
		}

		String sLType = "";
		Session session = HibernateSessionFactory.getSession();
		Iterator<String> it = mapLtLOs.keySet().iterator();
		while (it.hasNext()) {
			sLType = it.next();

			if (mapLTWrap.containsKey(sLType)) {
				ltWrap = mapLTWrap.get(sLType);
			} else
				continue;

			sql = getInitParamSql(ltWrap);

			ServerWithLog4j.logger.debug(sql);

			lstLO = mapLtLOs.get(sLType);
			PreparedStatement pst = session.connection().prepareStatement(sql);
			int size = lstLO.size();

			int i = 0;
			for (i = 0; i < size; i++) {
				setPreparedStatementParams(pst, ltWrap, lstLO.get(i));
				pst.addBatch();
				if ((i + 1) % BATCHSIZE == 0) {
					pst.executeBatch();
				}
			}

			pst.executeBatch();

			if (pst != null) {
				pst.close();
				pst = null;
			}
		}

		return los;
	}

	private String constructCreateSql(String tableName, LinkObject lo, Map<String, AttribItem> attrMap,
			Map<String, String> initSqlMap, long currentTime) throws Exception {
		String initSql = null;
		if (initSqlMap.containsKey(tableName)) {
			initSql = initSqlMap.get(tableName);
		} else {
			initSql = getInitSql(tableName, lo);
			initSqlMap.put(tableName, initSql);
		}
		StringBuilder sbSql = new StringBuilder(initSql);
		// 对象固有属性
		sbSql.append("'").append(lo.oid).append("'").append(",'").append(lo.creator).append("'")
				.append(",to_timestamp('").append(currentTime).append("','").append(DATEFORMATTER).append("')")
				.append(",'").append(lo.creator).append("'").append(",to_timestamp('").append(currentTime).append("','")
				.append(DATEFORMATTER).append("')").append(",'").append(lo.fromOid).append("'").append(",'")
				.append(lo.fromRevOid).append("'").append(",'").append(lo.fromNameOid).append("'").append(",'")
				.append(lo.fromBTName).append("'").append(",'").append(lo.toOid).append("'").append(",'")
				.append(lo.toRevOid).append("'").append(",'").append(lo.toNameOid).append("'").append(",'")
				.append(lo.toBTName).append("'").append(",to_timestamp('").append(currentTime).append("','")
				.append(DATEFORMATTER).append("')");
		for (int i = 0; i < lo.newAttrValList.length; i++) {
			AttributeValue abValue = lo.newAttrValList[i];
			AttribItem abItem = null;
			
			String attName = abValue.attrName.toLowerCase();
			if (attrMap.containsKey(attName)) {
				abItem = attrMap.get(attName);
			} else {
//				abItem = ServerServiceProvider.getOMDService().getAttributeService()
//						.getAttribItemByName(abValue.attrName.toLowerCase());
				abItem = OMCacheProvider.getAttribute(attName);
				attrMap.put(attName, abItem);
			}

			sbSql.append(",").append(getSqlAccordingType(abItem, lo.newAttrValList[i].attrVal));
		}

		lo.createTime = currentTime;
		lo.modifyTime = currentTime;
		lo.ts = currentTime;
		sbSql.append(")");
		String sql = sbSql.toString();
		return sql;
	}

//	private void setPreparedStatementParams(PreparedStatement pst, LinkObject lo , Map<String, AttribItem> attrMap) throws SQLException {
//
//		Timestamp curTime = new Timestamp(System.currentTimeMillis());
//		String sTime = curTime.toString();
//		
//		int index = 1;
//		pst.setString(index++, lo.oid);
//		pst.setString(index++, lo.creator);
//		pst.setTimestamp(index++, curTime);
//		pst.setString(index++, lo.creator);
//		pst.setTimestamp(index++, curTime);
//		pst.setString(index++, lo.fromOid);
//		pst.setString(index++, lo.fromRevisionOid);
//		pst.setString(index++, lo.fromNameOid);
//		pst.setString(index++, lo.fromBTMName);
//		pst.setString(index++, lo.toOid);
//		pst.setString(index++, lo.toRevisionOid);
//		pst.setString(index++, lo.toNameOid);
//		pst.setString(index++, lo.toBTMName);
//		pst.setTimestamp(index++, curTime);
//		
//		for (int i = 0; i < lo.newAttrValList.length; i++) {
//			AttributeValue abValue = lo.newAttrValList[i];
//			AttribItem abItem = null;
//			if (attrMap.containsKey(abValue.attrName.toLowerCase())) {
//				abItem = attrMap.get(abValue.attrName.toLowerCase());
//			} else {
//				abItem = ApProvider.getInstance().getAbItemByName(
//						abValue.attrName.toLowerCase());
//				attrMap.put(abValue.attrName.toLowerCase(), abItem);
//			}
//			
//			setQueryValueAccordingDataType(pst, abItem, index++, lo.newAttrValList[i].attrVal);
//		}		
//		
//		// 对象固有属性
////		sbSql.append("'").append(lo.oid).append("'")
////		        .append(",'").append(lo.creator).append("'")
////		        .append(",to_timestamp('").append(currentTime).append("','").append(DATEFORMATTER).append("')")
////		        .append(",'").append(lo.creator).append("'")
////		        .append(",to_timestamp('").append(currentTime).append("','").append(DATEFORMATTER).append("')")
////				.append(",'").append(lo.fromOid).append("'")
////				.append(",'").append(lo.fromRevisionOid).append("'")
////				.append(",'").append(lo.fromNameOid).append("'")
////				.append(",'").append(lo.fromBTMName).append("'")
////				.append(",'").append(lo.toOid).append("'")
////				.append(",'").append(lo.toRevisionOid).append("'")
////				.append(",'").append(lo.toNameOid).append("'")
////				.append(",'").append(lo.toBTMName).append("'")
////				.append(",to_timestamp('").append(currentTime).append("','").append(DATEFORMATTER).append("')");
////		for (int i = 0; i < lo.newAttrValList.length; i++) {
////			AttributeValue abValue = lo.newAttrValList[i];
////			AttribItem abItem = null;
////			if (attrMap.containsKey(abValue.attrName.toLowerCase())) {
////				abItem = attrMap.get(abValue.attrName.toLowerCase());
////			} else {
////				abItem = ApProvider.getInstance().getAbItemByName(
////						abValue.attrName.toLowerCase());
////				attrMap.put(abValue.attrName.toLowerCase(), abItem);
////			}
////			
////			sbSql.append(",").append(
////					getSqlAccordingType(abItem, lo.newAttrValList[i].attrVal));
////		}
//
//		lo.createTime = sTime;
//		lo.lastModifyTime = sTime;
//		lo.ts = sTime;
//	}
//	
	private void setPreparedStatementParams(PreparedStatement pst, LinkTypeWrap ltWrap, LinkObject lo)
			throws Exception {

		long time = System.currentTimeMillis();
		Timestamp curTime = new Timestamp(time);
		String sTime = curTime.toString();

		Map<String, AttribItem> attrMap = ltWrap.mapAttr;

		Map<String, String> mapValue = new HashMap<String, String>();
		for (AttributeValue av : lo.newAttrValList) {
			mapValue.put(av.attrName.toLowerCase(), av.attrVal);
		}

		int index = 1;
		pst.setString(index++, lo.oid);
		pst.setString(index++, lo.creator);
		pst.setTimestamp(index++, curTime);
		pst.setString(index++, lo.creator);
		pst.setTimestamp(index++, curTime);
		pst.setString(index++, lo.fromOid);
		pst.setString(index++, lo.fromRevOid);
		pst.setString(index++, lo.fromNameOid);
		pst.setString(index++, lo.fromBTName);
		pst.setString(index++, lo.toOid);
		pst.setString(index++, lo.toRevOid);
		pst.setString(index++, lo.toNameOid);
		pst.setString(index++, lo.toBTName);
		pst.setTimestamp(index++, curTime);

		String sField = "", sValue;
		for (int i = 0; i < ltWrap.ltItem.attributes.length; i++) {
			sField = ltWrap.ltItem.attributes[i].toLowerCase();
			AttribItem atItem = null;
			if (attrMap.containsKey(sField)) {
				atItem = attrMap.get(sField);
			} else {
				//atItem = ServerServiceProvider.getOMDService().getAttributeService().getAttribItemByName(sField);
				atItem = OMCacheProvider.getAttribute(sField);
				attrMap.put(sField, atItem);
			}

			if (mapValue.containsKey(sField))
				sValue = mapValue.get(sField);
			else
				sValue = null;

			setQueryValueAccordingDataType(pst, atItem, index++, sValue);
		}

		lo.createTime = time;
		lo.modifyTime = time;
		lo.ts = time;
	}

	private String getInitSql(String tableName, LinkObject lo) {
		String sql = "";
		StringBuffer sbFields = new StringBuffer(
				"OID,CREATOR,CREATETIME,LASTMODIFIER,LASTMODIFYTIME,F_OID,F_REVISIONOID,F_NAMEOID,F_BTWNAME,"
						+ "T_OID,T_REVISIONOID,T_NAMEOID,T_BTWNAME,TS");
		AttributeValue[] attrValList = lo.newAttrValList;
		for (int i = 0; i < attrValList.length; i++) {
			sbFields.append(",");
			sbFields.append(attrValList[i].attrName);
		}

		StringBuffer sbSql = new StringBuffer().append("INSERT INTO ").append(tableName).append("(")
				.append(sbFields.toString()).append(")").append(" VALUES (");
		sql = sbSql.toString();
		return sql;
	}

//	private String getInitParamSql(String tableName, LinkObject lo) {
//		String sql = "";
//		StringBuffer sbFields = new StringBuffer(
//				"OID,CREATOR,CREATETIME,LASTMODIFIER,LASTMODIFYTIME,F_OID,F_REVISIONOID,F_NAMEOID,F_BTWNAME,"
//						+ "T_OID,T_REVISIONOID,T_NAMEOID,T_BTWNAME,TS");
//		
//		StringBuffer sbParams = new StringBuffer("?,?,?,?,?,?,?,?,?,?,?,?,?,?");
//		
//		AttributeValue[] attrValList = lo.newAttrValList;
//		for (int i = 0; i < attrValList.length; i++) {
//			sbFields.append(",");
//			sbFields.append(attrValList[i].attrName);
//			
//			sbParams.append(",?");
//		}
//		
//		sql = String.format("INSERT INTO %s (%s) VALUES (%s)", tableName, sbFields.toString(), sbParams.toString());
//		
////		StringBuffer sbSql = new StringBuffer().append("INSERT INTO ")
////				.append(tableName).append("(").append(sbFields.toString())
////				.append(")").append(" VALUES (").append(sbParams.toString());
////		sql = sbSql.toString();
//		return sql;
//	}

	private String getInitParamSql(LinkTypeWrap ltWrap) {
		String sql = "";
		StringBuffer sbFields = new StringBuffer(
				"OID,CREATOR,CREATETIME,LASTMODIFIER,LASTMODIFYTIME,F_OID,F_REVISIONOID,F_NAMEOID,F_BTWNAME,"
						+ "T_OID,T_REVISIONOID,T_NAMEOID,T_BTWNAME,TS");

		StringBuffer sbParams = new StringBuffer("?,?,?,?,?,?,?,?,?,?,?,?,?,?");

		// AttributeValue[] attrValList = lo.newAttrValList;
		for (int i = 0; i < ltWrap.ltItem.attributes.length; i++) {
			sbFields.append(",");
			sbFields.append(ltWrap.ltItem.attributes[i]);

			sbParams.append(",?");
		}

		sql = String.format("INSERT INTO %s (%s) VALUES (%s)", ltWrap.tableName, sbFields.toString(),
				sbParams.toString());

//		StringBuffer sbSql = new StringBuffer().append("INSERT INTO ")
//				.append(tableName).append("(").append(sbFields.toString())
//				.append(")").append(" VALUES (").append(sbParams.toString());
//		sql = sbSql.toString();
		return sql;
	}

	/**
	 * 批量保存LO对象
	 * 
	 * @param los
	 * @return
	 * @throws Throwable
	 * @throws Exception
	 */
	public LinkObject[] batchCreateLinkObject(LinkObject[] los) throws Exception, Throwable {

		ServerWithLog4j.logger.info("====batchCreateLinkObject begin====");

		Map<String, List<LinkObject>> mapLOs = new HashMap<String, List<LinkObject>>();

		List<LinkObject> lstLO = null;
		for (LinkObject lo : los) {

			if (mapLOs.containsKey(lo.ltName))
				lstLO = mapLOs.get(lo.ltName);
			else {
				lstLO = new ArrayList<LinkObject>();
				mapLOs.put(lo.ltName, lstLO);
			}
			lstLO.add(lo);
		}

		ServerWithLog4j.logger.info("====batchCreateLinkObject Create LinkObjects====");

		LinkTypeWrap ltWrap = null;
		Iterator<String> its = mapLOs.keySet().iterator();
		while (its.hasNext()) {
			String sLType = its.next();

			ltWrap = new LinkTypeWrap();
			//ltWrap.ltItem = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(sLType);
			ltWrap.ltItem = OMCacheProvider.getLinkType(sLType);
			ltWrap.tableName = OmdHelper.getLTTableName(sLType);

			Map<String, AttribItem> attrMap = new HashMap<String, AttribItem>();
			//AttribItem[] items = ServerServiceProvider.getOMDService().getAttributeService().getAttribItemsByNames(ltWrap.ltItem.attributes);
			AttribItem[] items = OMCacheProvider.getAttributes(ltWrap.ltItem.attributes);
			for (int i = 0; i < items.length; i++) {
				attrMap.put(items[i].name, items[i]);
			}
			ltWrap.mapAttr = attrMap;

			// 调用单一业务类型的进行批量处理

			String sql = getInitParamSql(ltWrap);

			ServerWithLog4j.logger.debug(sql);

			lstLO = mapLOs.get(sLType);
			PreparedStatement pst = HibernateSessionFactory.getSessionConnection().prepareStatement(sql);
			int size = lstLO.size();

			int i = 0;
			for (i = 0; i < size; i++) {
				setPreparedStatementParams(pst, ltWrap, lstLO.get(i));
				pst.addBatch();
				if ((i + 1) % BATCHSIZE == 0) {
					pst.executeBatch();
				}
			}

			pst.executeBatch();

			if (pst != null) {
				pst.close();
				pst = null;
			}

			// batchCreateLinkObjectNoCheck(lstLO.toArray(new LinkObject[]{}), currentTime);
		}
		ServerWithLog4j.logger.info("====batchCreateLinkObject end====");

		return los;
	}

	public boolean createLinkObjectNotCommint(LinkObject lo) throws Exception, Throwable {
		String tableName = OmdHelper.getLTTableName(lo.ltName);

		Map<String, AttribItem> attrItemMap = getLOAttributeItemMap(lo.ltName);

		Session session = HibernateSessionFactory.getSession();
		String sql = getCreateLOSql(lo, tableName, attrItemMap);
		SQLQuery query = session.createSQLQuery(sql);
		prepareCreateLOPsmt(query, lo, attrItemMap);
		query.executeUpdate();
		return true;
	}

	/**
	 * 构建LO的创建SQL
	 * 
	 * @param bo
	 * @return
	 */
	private String getCreateLOSql(LinkObject lo, String tableName, Map<String, AttribItem> attrItemMap) {
		String sql = "";
		StringBuffer sbFields = new StringBuffer(
				"OID,CREATOR,CREATETIME,LASTMODIFIER,LASTMODIFYTIME,F_OID,F_REVISIONOID,F_NAMEOID,F_BTWNAME,"
						+ "T_OID,T_REVISIONOID,T_NAMEOID,T_BTWNAME,TS");
		AttributeValue[] attrValList = lo.newAttrValList;
		for (int i = 0; i < attrValList.length; i++) {
			if (!attrItemMap.containsKey(attrValList[i].attrName.toLowerCase())) {
				continue;
			}
			sbFields.append(",");
			sbFields.append(attrValList[i].attrName);
		}

		String[] allFields = sbFields.toString().split(",");
		StringBuffer sbValues = new StringBuffer();
		for (int i = 0; i < allFields.length; i++) {
			sbValues.append("?");
			if (i != allFields.length - 1) {
				sbValues.append(",");
			}
		}
		StringBuffer sbSql = new StringBuffer().append("INSERT INTO ").append(tableName).append("(")
				.append(sbFields.toString()).append(")").append(" VALUES (").append(sbValues.toString()).append(")");
		sql = sbSql.toString();
		return sql;
	}


	/**
	 * 准备创建数据
	 * 
	 * @param psmt
	 * @param bo
	 * @throws SQLException
	 */
	private void prepareCreateLOPsmt(SQLQuery query, LinkObject lo, Map<String, AttribItem> attrItemMap)
			throws SQLException {
		int index = 0;
		// 对象固有属性
		
		long curTime = System.currentTimeMillis();
		Timestamp currentTime = new Timestamp(curTime);
		if (lo.oid.equals("")) {
			lo.oid = ObjectUtility.getNewObjectID36(); // modify by zhonggy 2015-1-16
		}

		String userName = HibernateSessionFactory.getVciSessionInfo().userName;

		if (!StringUtils.isEmpty(userName))
			lo.creator = userName;

		if (!StringUtils.isEmpty(userName))
			lo.modifier = userName;

		query.setString(index++, lo.oid);
		query.setString(index++, lo.creator);
		query.setTimestamp(index++, currentTime);
		query.setString(index++, lo.modifier);
		query.setTimestamp(index++, currentTime);
		query.setString(index++, lo.fromOid);
		query.setString(index++, lo.fromRevOid);
		query.setString(index++, lo.fromNameOid);
		query.setString(index++, lo.fromBTName);
		query.setString(index++, lo.toOid);
		query.setString(index++, lo.toRevOid);
		query.setString(index++, lo.toNameOid);
		query.setString(index++, lo.toBTName);
		query.setTimestamp(index++, currentTime);
		// 对象特有属性
		for (int i = 0; i < lo.newAttrValList.length; i++) {
			if (!attrItemMap.containsKey(lo.newAttrValList[i].attrName.toLowerCase())) {
				continue;
			}
			AttributeValue abValue = lo.newAttrValList[i];
			AttribItem abItem = attrItemMap.get(abValue.attrName.toLowerCase());
			setQueryValueAccordingDataType(query, abItem, index++, lo.newAttrValList[i].attrVal);
		}
		lo.createTime = curTime;
		lo.modifyTime = curTime;
		lo.ts = curTime;
	}

	/**
	 * 关闭stamement连接
	 * 
	 * @param psmt
	 */
	private void close(Statement psmt) {
		try {
			if (psmt != null) {
				psmt.close();
				psmt = null;
			}
		} catch (SQLException e) {
			;
		}
	}

	private void close(ResultSet rs) {
		try {
			if (rs != null) {
				rs.close();
				rs = null;
			}
		} catch (SQLException e) {
			;
		}
	}

	/**
	 * 更改LO的属性值
	 * 
	 * @param bo
	 * @return
	 * @throws SQLException
	 */
	public boolean updateLinkObject(LinkObject lo, Map<String, String> attrMap) throws SQLException {
		String tableName = OmdHelper.getLTTableName(lo.ltName);

		Session session = HibernateSessionFactory.getSession();

		String sql = getUpdateLOSql(lo, tableName, attrMap);
		SQLQuery query = session.createSQLQuery(sql);
		prepareUpdateLOPsmt(query, lo, attrMap);
		query.executeUpdate();

		return true;
	}

	/**
	 * 批量更改LO对象属性值
	 * 
	 * @param los
	 * @return
	 * @throws Throwable
	 * @throws Exception
	 */
	public boolean batchUpdateLinkObject(LinkObject[] los) throws Exception, Throwable {
		Map<String, Map<String, String>> loAttrMap = new HashMap<String, Map<String, String>>();
		for (LinkObject lo : los) {
			if (loAttrMap.get(lo.ltName) == null) {
				Map<String, String> attrMap = this.getLOAttributeItemDefaultValMap(lo.ltName);
				loAttrMap.put(lo.ltName, attrMap);
			}
			updateLinkObject(lo, loAttrMap.get(lo.ltName));
		}

		return true;
	}

	boolean isLOAttribute(String attrName, Map<String, String> attrMap) {
		if (attrMap.containsKey(attrName.toLowerCase()) || attrMap.containsKey(attrName.toUpperCase())
				|| LinkConstants.isLinkConstants(attrName.toUpperCase())) {
			return true;
		} else {
			return false;
		}
	}

	/**
	 * 准备更改LO属性的SQL语句
	 * 
	 * @param lo
	 * @return
	 */
	private String getUpdateLOSql(LinkObject lo, String tableName, Map<String, String> attrMap) {
		String sql = "";

		StringBuffer sbSql = new StringBuffer().append("UPDATE ").append(tableName).append(" set ")
				.append("LASTMODIFIER = ?").append(", LASTMODIFYTIME = ?");
		// Set<String> set = LinkConstants.SELECT_NOT_TO_CONSTANTS.keySet();
		for (int i = 0; i < lo.newAttrValList.length; i++) {
			/*
			 * if (set.contains(lo.newAttrValList[i].attrName)) { continue; }
			 */
			if (!isLOAttribute(lo.newAttrValList[i].attrName, attrMap)) { // modify by zhonggy 2015-1-3
				continue;
			}
			sbSql.append(", ");
			sbSql.append(lo.newAttrValList[i].attrName).append("=?");
		}
		// 2013-12-03增加 更新"TS"逻辑（gaonb）
		sbSql.append(" ,TS = ?");
		// 2013-12-03增加 更新"TS"逻辑（gaonb）
		sbSql.append(" WHERE OID = ? and TS = ?");
		sql = sbSql.toString();
		return sql;
	}

	/**
	 * 准备更改属性值
	 * 
	 * @param psmt
	 * @param bo
	 * @throws SQLException
	 */
	private void prepareUpdateLOPsmt(SQLQuery query, LinkObject lo, Map<String, String> attrMap) throws SQLException {
		int index = 0;
		
		long curTime = System.currentTimeMillis();
		Timestamp ts = new Timestamp(curTime);
		// 对象特有属性
		// query.setString(index++, lo.lastModifier);
		// 对象保存修改人后台统一处理 modify by zhonggy 2015-1-3

		String userName = HibernateSessionFactory.getVciSessionInfo().userName;
		if (!StringUtils.isBlank(userName)) {
			lo.creator = userName;
			lo.modifier = userName;
		}

		query.setString(index++, lo.creator);
		query.setTimestamp(index++, ts);
		// Set<String> set = LinkConstants.SELECT_NOT_TO_CONSTANTS.keySet();
		for (int i = 0; i < lo.newAttrValList.length; i++) {
			/*
			 * if (set.contains(lo.newAttrValList[i].attrName)) { continue; }
			 */
			if (!isLOAttribute(lo.newAttrValList[i].attrName, attrMap)) { // modify by zhonggy 2015-1-3
				continue;
			}
			query.setString(index++, lo.newAttrValList[i].attrVal);
		}

		// 2013-12-03增加 更新"TS"逻辑（gaonb）
		query.setTimestamp(index++, ts);
		// 2013-12-03增加 更新"TS"逻辑（gaonb）
		// 对象固有属性
		query.setString(index++, lo.oid);
		query.setTimestamp(index++, new Timestamp(lo.ts));
		// lo.lastModifier = HibernateSessionFactory.getVciSessionInfo().userName;
		// //对象保存修改人后台统一处理 modify by zhonggy 2015-1-3
		lo.ts = curTime;
		lo.modifyTime = curTime;
	}

	/**
	 * 删除LO对象
	 * 
	 * @param lo
	 * @return
	 * @throws SQLException
	 */
	public boolean deleteLinkObject(LinkObject lo) throws SQLException {
		String tableName = OmdHelper.getLTTableName(lo.ltName);

		Session session = HibernateSessionFactory.getSession();

		String sql = getDeleteLOSql(lo, tableName);
		SQLQuery query = session.createSQLQuery(sql);
		prepareDeleteLOPsmt(query, lo);
		query.executeUpdate();

		return true;
	}

	/**
	 * 批量删除LO对象
	 * 
	 * @param los
	 * @return
	 * @throws SQLException
	 */
	public boolean batchDeleteLinkObject(LinkObject[] los) throws SQLException {
		for (LinkObject lo : los) {
			deleteLinkObject(lo);
		}

		return true;
	}

	/**
	 * 删除处于from端对象管理的Link
	 * 
	 * @param los
	 * @param bo
	 */
	public void deleteLinksByFromObj(String[] linkTypeNames, BusinessObject bo, int type) {
		for (int i = 0; i < linkTypeNames.length; i++) {
			deleteSingleLinkByFromObj(linkTypeNames[i], bo, type);
		}
	}

	public void getBatchDeleteLinksByFromObj(String[] linkTypeNames, BusinessObject bo, int type, List<String> sqlList,
			Map<String, String> tableMap) {
		String tableName;
		for (int i = 0; i < linkTypeNames.length; i++) {
			if (tableMap.get(linkTypeNames[i]) != null) {
				tableName = tableMap.get(linkTypeNames[i]);
			} else {
				tableName = OmdHelper.getLTTableName(linkTypeNames[i]);
				tableMap.put(linkTypeNames[i], tableName);
			}
			sqlList.add(getDeleteSingleLinkSqlByFromObj(tableName, bo, type));
		}
	}

	public void deleteSingleLinkByFromObj(String linkTypeName, BusinessObject bo, int type) {
		String tableName = OmdHelper.getLTTableName(linkTypeName);

		String sql = "";
		StringBuffer sbSql = new StringBuffer().append("DELETE FROM ").append(tableName).append(" WHERE ");
		if (type == 1) {
			sbSql.append("F_OID = '").append(bo.oid);
		} else if (type == 2) {
			sbSql.append("F_REVISIONOID = '").append(bo.revisionid);
		} else if (type == 3) {
			sbSql.append("F_NAMEOID = '").append(bo.nameoid);
		}
		sbSql.append("'");
		sql = sbSql.toString();
		SQLQuery query = HibernateSessionFactory.getSession().createSQLQuery(sql);
		query.executeUpdate();
	}

	private String getDeleteSingleLinkSqlByFromObj(String tableName, BusinessObject bo, int type) {
		String sql = "";
		StringBuffer sbSql = new StringBuffer().append("DELETE FROM ").append(tableName).append(" WHERE ");
		if (type == 1) {
			sbSql.append("F_OID = '").append(bo.oid);
		} else if (type == 2) {
			sbSql.append("F_REVISIONOID = '").append(bo.revisionid);
		} else if (type == 3) {
			sbSql.append("F_NAMEOID = '").append(bo.nameoid);
		}
		sbSql.append("'");
		sql = sbSql.toString();

		return sql;
	}

	/**
	 * shanch
	 * 
	 * @param los
	 * @param bo
	 */
	public void deleteLinksbyToObj(String[] linkTypeNames, BusinessObject bo, int type) {
		for (int i = 0; i < linkTypeNames.length; i++) {
			deleteSingleLinkbyToObj(linkTypeNames[i], bo, type);
		}
	}

	public void getBatchDeleteLinksByToObj(String[] linkTypeNames, BusinessObject bo, int type, List<String> sqlList,
			Map<String, String> tableMap) {
		String tableName;
		for (int i = 0; i < linkTypeNames.length; i++) {
			if (tableMap.get(linkTypeNames[i]) != null) {
				tableName = tableMap.get(linkTypeNames[i]);
			} else {
				tableName = OmdHelper.getLTTableName(linkTypeNames[i]);
				tableMap.put(linkTypeNames[i], tableName);
			}
			sqlList.add(getDeleteSingleLinkSqlbyToObj(tableName, bo, type));
		}
	}

	public void deleteSingleLinkbyToObj(String linkTypeName, BusinessObject bo, int type) {
		String tableName = OmdHelper.getLTTableName(linkTypeName);

		String sql = "";
		StringBuffer sbSql = new StringBuffer().append("DELETE FROM ").append(tableName).append(" WHERE ");
		if (type == 1) {
			sbSql.append("T_OID = '").append(bo.oid);
		} else if (type == 2) {
			sbSql.append("T_REVISIONOID = '").append(bo.revisionid);
		} else if (type == 3) {
			sbSql.append("T_NAMEOID = '").append(bo.nameoid);
		}
		sbSql.append("'");
		sql = sbSql.toString();
		SQLQuery query = HibernateSessionFactory.getSession().createSQLQuery(sql);
		query.executeUpdate();
	}

	private String getDeleteSingleLinkSqlbyToObj(String tableName, BusinessObject bo, int type) {
		String sql = "";
		StringBuffer sbSql = new StringBuffer().append("DELETE FROM ").append(tableName).append(" WHERE ");
		if (type == 1) {
			sbSql.append("T_OID = '").append(bo.oid);
		} else if (type == 2) {
			sbSql.append("T_REVISIONOID = '").append(bo.revisionid);
		} else if (type == 3) {
			sbSql.append("T_NAMEOID = '").append(bo.nameoid);
		}
		sbSql.append("'");
		sql = sbSql.toString();

		return sql;
	}

	/**
	 * 构建删除LO的SQL语句
	 * 
	 * @param lo
	 * @return
	 */
	private String getDeleteLOSql(LinkObject lo, String tableName) {
		String sql = "";

		StringBuffer sbSql = new StringBuffer().append("DELETE FROM ").append(tableName).append(" WHERE OID = ?");
		// 2013-12-03 增加TS判断逻辑（gaonb）
		sql = sbSql.append(" and TS =? ").toString();
		// 2013-12-03 增加TS判断逻辑（gaonb）
		return sql;
	}

	/**
	 * 准备删除LO的数据
	 * 
	 * @param psmt
	 * @param bo
	 * @throws SQLException
	 */
	private void prepareDeleteLOPsmt(SQLQuery query, LinkObject lo) throws SQLException {
		int index = 0;

		// 对象固有属性
		query.setString(index++, lo.oid);
		// 2013-12-03 删除增加TS判断逻辑
		query.setTimestamp(index++, new Timestamp(lo.ts));
		// 2013-12-03 删除增加TS判断逻辑
	}

	/**
	 * 根据对象ID获取对象的指定属性列值
	 * 
	 * @param oid
	 * @param linkTypeName
	 * @param queryColumns
	 * @return
	 * @throws Throwable
	 * @throws Exception
	 */
	@SuppressWarnings("deprecation")
	public LinkObject[] getLinkObjectByBO(BusinessObject bo, String linkTypeName, boolean isFrom)
			throws Exception, Throwable {
		String tableName = OmdHelper.getLTTableName(linkTypeName);

		AttribItem[] loAttributes = getLOAttributeItem(linkTypeName);

		String sql = getSelectLOSql(bo.oid, tableName, loAttributes, isFrom);
		Session session = HibernateSessionFactory.getSession();

		Statement stmt = session.connection().createStatement();
		ResultSet rs = stmt.executeQuery(sql);
		ArrayList<LinkObject> los = new ArrayList<LinkObject>();
		LinkObject lo = null;
		while (rs.next()) {
			lo = createLOByRS(rs, loAttributes);
			lo.ltName = linkTypeName;

			los.add(lo);
		}
		close(rs);
		close(stmt);

		return los.toArray(new LinkObject[0]);
	}

	private LinkObject createLOByRS(ResultSet rs, AttribItem[] loAttributes) throws SQLException {
		LinkObject lo = new LinkObject();
		
		int index = 1;
		lo.oid = rs.getString(index++);
		lo.creator = rs.getString(index++);
		lo.createTime = rs.getTimestamp(index++).getTime();
		lo.modifier = rs.getString(index++);
		lo.modifyTime = rs.getTimestamp(index++).getTime();
		lo.fromOid = rs.getString(index++);
		lo.fromRevOid = rs.getString(index++);
		lo.fromNameOid = rs.getString(index++);
		lo.fromBTName = rs.getString(index++);
		lo.toOid = rs.getString(index++);
		lo.toRevOid = rs.getString(index++);
		lo.toNameOid = rs.getString(index++);
		lo.toBTName = rs.getString(index++);
		lo.ts = rs.getTimestamp(index++).getTime();

		ArrayList<AttributeValue> list = new ArrayList<AttributeValue>();
		for (int i = 0; i < loAttributes.length; i++) {
			AttributeValue attrVal = new AttributeValue();
			attrVal.attrName = loAttributes[i].name;
			attrVal.attrVal = rs.getString(index++);
			list.add(attrVal);
		}
		lo.newAttrValList = new AttributeValue[0];
		lo.hisAttrValList = list.toArray(new AttributeValue[list.size()]);
		return lo;
	}
//	
//	/**
//	 * 根据对象ID获取对象的指定属性列值
//	 * 
//	 * @param oid
//	 * @param linkTypeName
//	 * @param queryColumns
//	 * @return
//	 * @throws Throwable
//	 * @throws Exception
//	 */
//	@SuppressWarnings("deprecation")
//	public LinkObject[] getLinkObjectByToBO(BusinessObject bo, String linkTypeName, boolean isFrom)
//			throws Exception, Throwable {
//		String tableName = getLinkTypeTableName(linkTypeName);
//
//		Session session = HibernateSessionFactory.getSession();
//
//		AttribItem[] loAttributes = getLOAttributeItem(linkTypeName);
//
//		String sql = getSelectLOSql(bo.oid, tableName, loAttributes, isFrom);
//		Statement stmt = session.connection().createStatement();
//		ResultSet rs = stmt.executeQuery(sql);
//		ArrayList<LinkObject> los = new ArrayList<LinkObject>();
//		LinkObject lo = null;
//		while (rs.next()) {
//			lo = new LinkObject();
//			int index = 1;
//			lo.oid = rs.getString(index++);
//			lo.creator = rs.getString(index++);
//			lo.createTime = String.valueOf(rs.getTimestamp(index++));
//			lo.lastModifier = rs.getString(index++);
//			lo.lastModifyTime = String.valueOf(rs.getTimestamp(index++));
//			lo.fromOid = rs.getString(index++);
//			lo.fromRevisionOid = rs.getString(index++);
//			lo.fromNameOid = rs.getString(index++);
//			lo.fromBTMName = rs.getString(index++);
//			lo.toOid = rs.getString(index++);
//			lo.toRevisionOid = rs.getString(index++);
//			lo.toNameOid = rs.getString(index++);
//			lo.toBTMName = rs.getString(index++);
//			lo.ts = String.valueOf(rs.getTimestamp(index++));
//
//			lo.linkTypeName = linkTypeName;
//
//			ArrayList<AttributeValue> list = new ArrayList<AttributeValue>();
//			for (int i = 0; i < loAttributes.length; i++) {
//				AttributeValue attrVal = new AttributeValue();
//				attrVal.attrName = loAttributes[i].name;
//				attrVal.attrVal = rs.getString(index++);
//				list.add(attrVal);
//			}
//			lo.newAttrValList = new AttributeValue[0];
//			lo.hisAttrValList = list.toArray(new AttributeValue[list.size()]);
//			los.add(lo);
//		}
//		close(rs);
//		close(stmt);
//
//		return los.toArray(new LinkObject[0]);
//	}
	/**
	 * 根据id和链接类型名称获取指定的链接对象
	 * 
	 * @param oid
	 * @param linkTypeName
	 * @return
	 */
	public LinkObject readLinkObjectById(String oid, String linkTypeName) throws Exception, Throwable {
		String tableName = OmdHelper.getLTTableName(linkTypeName);

		AttribItem[] loAttributes = getLOAttributeItem(linkTypeName);

		String sql = getSelectLOByIdSql(oid, tableName, loAttributes);
		Session session = HibernateSessionFactory.getSession();

		Statement stmt = session.connection().createStatement();
		ResultSet rs = stmt.executeQuery(sql);

		LinkObject lo = new LinkObject();
		if (rs.next()) {
			lo = createLOByRS(rs, loAttributes);
			lo.ltName = linkTypeName;
		}
		close(rs);
		close(stmt);
		
		return lo;

//		SQLQuery query = session.createSQLQuery(sql);
//		List<?> queryList = query.list();
//		if (queryList == null || queryList.size() < 1) {
//			return new LinkObject();
//		}
//
//		Object[] array = (Object[]) queryList.get(0);
//		ServerLinkObject slo = new ServerLinkObject();
//		String[] queryColumns = slo.getQueryColumnAccordingToSQL(sql, "SELECT", "FROM " + tableName);
//
//		String attrType = "";
//		int j = 0;
//		for (int i = 0; i < array.length; i++) {
//			if (i < array.length - loAttributes.length) {
//				attrType = "";
//			} else {
//				attrType = loAttributes[j++].vtDataType;
//			}
//			slo.setAttributeValue(queryColumns[i], attrType, array[i]);
//		}
//
//		LinkObject lo = slo.getLinkObject();
//		lo.ltName = linkTypeName;

//		return slo.getLinkObject();
	}

	/**
	 * 构建查询SQL语句
	 * 
	 * @param oid
	 * @param ltName
	 * @param queryColumns
	 * @return
	 */
	private String getSelectLOSql(String fromOId, String tableName, AttribItem[] queryColumns, boolean isFrom) {
		String sql = "";
		StringBuffer sbFields = new StringBuffer(
				"SELECT OID,CREATOR,CREATETIME,LASTMODIFIER,LASTMODIFYTIME,F_OID,F_REVISIONOID,F_NAMEOID,F_BTWNAME,"
						+ "T_OID,T_REVISIONOID,T_NAMEOID,T_BTWNAME,TS");
		for (int i = 0; i < queryColumns.length; i++) {
			sbFields.append(",");
			sbFields.append(queryColumns[i].name);
		}
		sbFields.append(" FROM ").append(tableName).append(" p where ");
		if (isFrom) {
			sbFields.append("p.F_OID");
		} else {
			sbFields.append("p.T_OID");
		}
		sbFields.append(" = '").append(fromOId).append("'");
		sql = sbFields.toString();
		return sql;
	}

	/**
	 * 获取根据oid，类型获取链接对象的查询语句
	 * 
	 * @param oid
	 * @param tableName
	 * @param queryColumns
	 * @return
	 */
	private String getSelectLOByIdSql(String oid, String tableName, AttribItem[] queryColumns) {
		String sql = "";
		StringBuffer sbFields = new StringBuffer(
				"SELECT OID,CREATOR,CREATETIME,LASTMODIFIER,LASTMODIFYTIME,F_OID,F_REVISIONOID,F_NAMEOID,F_BTWNAME,"
						+ "T_OID,T_REVISIONOID,T_NAMEOID,T_BTWNAME,TS");
		for (int i = 0; i < queryColumns.length; i++) {
			sbFields.append(",");
			sbFields.append(queryColumns[i].name);
		}
		sbFields.append(" FROM ").append(tableName).append(" p where p.OID = '").append(oid).append("'");
		sql = sbFields.toString();
		return sql;
	}
}