package com.vci.server.query.service;

import java.math.BigDecimal;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;

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

import com.vci.corba.omd.btm.BtmItem;
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.ObjectQueryService;
import com.vci.corba.query.data.BOAndLO;
import com.vci.corba.query.data.KV;
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.ServerServiceProvider;
import com.vci.server.cache.OMCacheProvider;
import com.vci.server.query.parsers.Parser;
import com.vci.server.query.util.QTSqlUtil;
import com.zeroc.Ice.Current;
import com.vci.common.exception.VciExceptionTool;
import com.vci.common.qt.object.Condition;
import com.vci.common.qt.object.QTConstants;
import com.vci.common.qt.object.QueryTemplate;
import com.vci.corba.common.VCIError;

/**
 * 分段策略查询
 * 当链接查询多个业务类型时， 为满足递归查询实行二次查询：第一次查询link表，第二次分段查询btm表
 * @author zhouhui
 *
 */
public abstract class QTServiceImplPartationStrategy implements ObjectQueryService{
	private DateFormat dFormat = new SimpleDateFormat("yyyy-MM-dd");
	private Date date = Calendar.getInstance().getTime();

	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;
	}
	
	/**
	 * 根据查询模板名, 查询模板内容查询业务对象
	 */
	@Override
	public BusinessObject[] findBTMObjects(String qtName, String qtText, Current current)
			throws VCIError {
		try {
			List<BusinessObject> boList = new ArrayList<BusinessObject>();
//			Document doc = null;
//			doc = DocumentHelper.parseText(qtText);
//			if(doc == null){
//				return boList.toArray(new BusinessObject[0]);
//			}
			QueryTemplate qt = OQueryHelper.getQTByQTText(qtName, qtText);
			if(qt == null){
				return boList.toArray(new BusinessObject[0]);
			}
			boList = QueryObjectService.getInstance().findBtmObjects(qt);
			if(qt.isQueryChildren()){
				//查询子类型
				BtmItem[] btms = ServerServiceProvider.getOMDService().getBTMService().getChildrenBtms(qt.getBtmType());
				for(int i = 0; i < btms.length; i++){
					qt.setBtmType(btms[i].name);
					boList.addAll(QueryObjectService.getInstance().findBtmObjects(qt));
				}
			}
			return boList.toArray(new BusinessObject[0]);
		} catch (Throwable e) {
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00001", e);
		}
	}

	/**
	 * 根据查询模板名, 查询模板内容查询链接对象
	 */
	@Override
	public LinkObject[] findLTObjects(String qtName, String qtText, Current current)
			throws VCIError {
		try {
			List<LinkObject> loList = new ArrayList<LinkObject>();
//			Document doc = null;
//			doc = DocumentHelper.parseText(qtText);
//			if(doc == null){
//				return loList.toArray(new LinkObject[0]);
//			}
			QueryTemplate qt = OQueryHelper.getQTByQTText(qtName, qtText);
			if(qt == null){
				return loList.toArray(new LinkObject[0]);
			}
			String btmType = qt.getBtmType();
			if(btmType != null && btmType.equals("*")){
				String ltName = qt.getLinkType();
				//LinkType lt = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(ltName);
				LinkType lt = OMCacheProvider.getLinkType(ltName);
				//当linkType的from或者to端的业务类型只有一个时，按现有方式处理
				if(lt.btmItemsFrom.length < 2 || lt.btmItemsTo.length < 2){
					String[] btmNames = null;
					if(qt.getDirection().equals(QTConstants.DIRECTION_OPPOSITE)){
						btmNames = lt.btmItemsFrom;
					}else{
						btmNames = lt.btmItemsTo;
					}
					List<LinkObject> list = new ArrayList<LinkObject>();
					for(int i = 0; i < btmNames.length; i++){
						qt.setBtmType(btmNames[i]);
						list.addAll(QueryObjectService.getInstance().findLinkObject(qt));
					}
					int recReturnMode = qt.getRecReturnMode();
					//对查询结果进行过滤
					if(recReturnMode == QTConstants.RECRETURNMODE_FILTER){
						list = QueryObjectService.getInstance().filterLos(list);
					}
					return list.toArray(new LinkObject[0]);
				//否则, 采用二次查询来处理
				}else{
//					List<LinkObject> list = QueryObject.getInstance().findLinkObjectByTwiceQuery(qt);
					//在方法内查询完 lo查询bo之前进行过滤处理
					List<LinkObject> list = QueryObjectPartationStrategy.getInstance().findLinkObjectByPartion(qt);
					return list.toArray(new LinkObject[0]);
				}
			}else{
				loList = QueryObjectService.getInstance().findLinkObject(qt);
				int recReturnMode = qt.getRecReturnMode();
				//对查询结果进行过滤
				if(recReturnMode == QTConstants.RECRETURNMODE_FILTER){
					loList = QueryObjectService.getInstance().filterLos(loList);
				}
			}
			return loList.toArray(new LinkObject[0]);
		} catch (Throwable e) {
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00002", e);
		}
	}


	/**
	 * 根据查询模板获取linkObject 和 关联的businessObject
	 */
	@Override
	public BOAndLO[] getBOAndLOS(String qtName, String qtText, String btmOId, Current current) throws VCIError {
		try{
//			Document doc = DocumentHelper.parseText(qtText);
//			if(doc == null){
//				return new BOAndLO[0];
//			}
			QueryTemplate qt = OQueryHelper.getQTByQTText(qtName, qtText);
			if(qt == null){
				return new BOAndLO[0];
			}
			if(qt.getBtmType().equals("*")){
				String ltName = qt.getLinkType();
				//LinkType lt = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(ltName);
				LinkType lt = OMCacheProvider.getLinkType(ltName);
				//当linkType的form或者to端的业务类型只有一个时，按现有方式处理
				if(lt.btmItemsFrom.length < 2 || lt.btmItemsTo.length < 2){
					String[] btmNames = null;
					if(qt.getDirection().equals(QTConstants.DIRECTION_OPPOSITE)){
						btmNames = lt.btmItemsFrom;
					}else{
						btmNames = lt.btmItemsTo;
					}
					List<BOAndLO> list = new ArrayList<BOAndLO>();
					for(int i = 0; i < btmNames.length; i++){
						qt.setBtmType(btmNames[i]);
						list.addAll(QueryObjectPartationStrategy.getInstance().findBOAndLOList(qt));
					}
					
					int recReturnMode = qt.getRecReturnMode();
					//对查询结果进行过滤
					if(recReturnMode == QTConstants.RECRETURNMODE_FILTER){
						list = QueryObjectService.getInstance().filterLoAndBOs(list);
					}
					return list.toArray(new BOAndLO[0]);
				//否则, 二次查询处理
				}else{
//					List<BOAndLO> list = QueryObject.getInstance().findBOAndLOByTwiceQuery(qt);
					//查询完los在查询bos之前进行过滤
					List<BOAndLO> list = QueryObjectPartationStrategy.getInstance().findBOAndLOByPartion(qt);
					return list.toArray(new BOAndLO[0]);
				}
			}else{
				List<BOAndLO> list = QueryObjectPartationStrategy.getInstance().findBOAndLOList(qt);
				
				int recReturnMode = qt.getRecReturnMode();
				//对查询结果进行过滤
				if(recReturnMode == QTConstants.RECRETURNMODE_FILTER){
					list = QueryObjectService.getInstance().filterLoAndBOs(list);
				}
				return list.toArray(new BOAndLO[0]);
			}
		}catch(Throwable e){
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00007", e);
		}
	}

	/**
	 * 根据业务类型名, 版本条件查询业务对象  
	 * version: 0:所有版次; 1:当前版本当前版次; 2:当前版本最新版次; 3:最新版本最新版次.
	 */
	@Override
	public BusinessObject[] findBTMObjectsByTypeNameAndVersion(String typeName,
			short version, Current current) throws VCIError {
		try{
			List<BusinessObject> boList = new ArrayList<BusinessObject>();
			QueryTemplate qt = new QueryTemplate();
			qt.setType(QTConstants.TYPE_BTM);
			qt.setBtmType(typeName);
			List<String> clauseList = new ArrayList<String>();
			clauseList.add("*");
			qt.setClauseList(clauseList);
			qt.setVersion(version);
			boList = QueryObjectService.getInstance().findBtmObjects(qt);
			
			
			return boList.toArray(new BusinessObject[0]);
		}catch(Throwable e){
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00010", e);
		}
	}
	
	/**
	 * 根据查询模板名, 查询模板内容返回查询总数
	 */
	@Override
	public long findTotalCount(String qtName, String qtText, Current current) throws VCIError {
		try {
			int totalCount = 0;
			//Document doc = DocumentHelper.parseText(qtText);
			QueryTemplate qt = OQueryHelper.getQTByQTText(qtName, qtText);
			if(qt.getType().equals(QTConstants.TYPE_LINK) && qt.getBtmType().equals("*")){
				String ltName = qt.getLinkType();
				//LinkType lt = ServerServiceProvider.getOMDService().getLinkTypeService().getLinkType(ltName);
				LinkType lt = OMCacheProvider.getLinkType(ltName);
				String[] btmNames = null;
				if(qt.getDirection().equals(QTConstants.DIRECTION_OPPOSITE)){
					btmNames = lt.btmItemsFrom;
				}else{
					btmNames = lt.btmItemsTo;
				}
				for(int i = 0; i < btmNames.length; i++){
					qt.setBtmType(btmNames[i]);
					StringBuilder sql = new StringBuilder();
					sql.append("select count(*) from ");
					
					Parser parser = new Parser(qt);
					String queryType = parser.getQueryType();
					sql.append(queryType);
					sql.append(" where 1 = 1 ");
					Condition condition = qt.getCondition();
					if(condition != null){
						sql.append("and ");
						//sql.append(condition.getSql(qt, true));
						sql.append(QTSqlUtil.getSql(qt, true));
					}
					sql.append(parser.getRevConstraint());
					sql.append(parser.getVerConstraint());
					if(parser.isRightSwitch() && qt.getType().equals(QTConstants.TYPE_BTM)){
						if(qt.isRightFlag()){
							sql.append(parser.getGrandRightSQL());
						}
					}
					sql.append(parser.getSecretCheckSql());
					
					Session session = HibernateSessionFactory.getSession();
					SQLQuery sqlQuery = session.createSQLQuery(sql.toString());
					List list = sqlQuery.list();
					totalCount += ((BigDecimal)list.get(0)).intValue();
				}
				return totalCount;
			}else{
				StringBuilder sql = new StringBuilder();
				sql.append("select count(*) from ");
				
				Parser parser = new Parser(qt);
				String queryType = parser.getQueryType();
				sql.append(queryType);
				sql.append(" where 1 = 1 ");
				Condition condition = qt.getCondition();
				if(condition != null){
					sql.append("and ");
					//sql.append(condition.getSql(qt, true));
					sql.append(QTSqlUtil.getSql(qt, true));
				}
				sql.append(parser.getRevConstraint());
				sql.append(parser.getVerConstraint());
				if(parser.isRightSwitch() && qt.getType().equals(QTConstants.TYPE_BTM)){
					if(qt.isRightFlag()){
						sql.append(parser.getGrandRightSQL());
					}
				}
				sql.append(parser.getSecretCheckSql());
				
				Session session = HibernateSessionFactory.getSession();
				SQLQuery sqlQuery = session.createSQLQuery(sql.toString());
				List list = sqlQuery.list();
				totalCount = ((BigDecimal)list.get(0)).intValue();
				return totalCount;
			}
		}catch(Throwable e){
			e.printStackTrace();
			throw getLocalVciError("P0010QT-00012", e);
		}
		
	}

	@Override
	public KV[][] queryBySql(String sql, Current current) throws VCIError {
		// TODO Auto-generated method stub
		return null;
	}

}