package com.vci.server.query.util;

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

import org.dom4j.DocumentException;

import com.vci.server.base.utility.OQueryHelper;
import com.vci.server.query.delegate.ObjectQueryServiceDelegate;
import com.vci.common.qt.object.Condition;
import com.vci.common.qt.object.OrderInfo;
import com.vci.common.qt.object.PageInfo;
import com.vci.common.qt.object.QTConstants;
import com.vci.common.qt.object.QueryTemplate;
import com.vci.corba.common.VCIError;
import com.vci.corba.omd.data.BusinessObject;
import com.vci.corba.query.data.BOAndLO;

public class DataModelServerProcessor implements IDataModelServerProcessor {

	/**
	 * 根据输入参数自定义查询模板，根据自定义的查询模板获取符合条件的业务对象查询结果
	 * @param btmName，业务类型名称
	 * @param clauseList，返回的字段列表，暂时默认支持*
	 * @param queryChildrenFlag，是否查询子业务类型的数据
	 * @param rightFlag，是否根据数据授权过滤，true：进行数据授权过滤，false：不进行数据授权过滤
	 * @param queryCondition，查询条件map，即需要附加到业务类型的查询语句的查询条件
	 * @param version，1：当前版本当前版次；2代表当前版本最新版次；3：代表最新版本最新版次；4代表当前发布有效版
	 * @param pageInfo，分页信息，不需要分页时将其设为null即可，其包含两个属性：pageNO：页数和rowCount：当前页显示条数
	 * @param orderInfoList，排序信息，不需要是将其设置为null， 其包含三个属性：level:排序优先级，数越小越优先； orderField：排序字段名称;orderMode：属性ASC或DESC;
	 * @return
	 * @throws VCIError
	 * @throws DocumentException
	 */
	@Override
	public BusinessObject[] getBusinessObjectByCondition(String btmName, List<String> clauseList, boolean queryChildrenFlag, boolean rightFlag, 
			Map<String, String> queryCondition, int version, PageInfo pageInfo, List<OrderInfo> orderInfoList) throws VCIError {
			BusinessObject[] bos = null;
			try{
				QueryTemplate qt2 = new QueryTemplate();
				qt2.setId("btmQuery");
				qt2.setBtmType(btmName);
				qt2.setType("btm");
				clauseList = new ArrayList<String>();
				clauseList.add("*");
				qt2.setClauseList(clauseList);
				qt2.setQueryChildrenFlag(queryChildrenFlag);
				qt2.setRightFlag(rightFlag);
				qt2.setVersion(version);
				if (pageInfo != null && pageInfo.getPageNO() > 0 && pageInfo.getRowCount() > 0) {
					qt2.setPageInfo(pageInfo);
				}
				if (orderInfoList != null && orderInfoList.size() > 0) {
					qt2.setOrderInfoList(orderInfoList);
				}
				
				if (queryCondition != null && queryCondition.size() > 0) {
					Condition cond = OQueryHelper.getCondition(queryCondition);
					qt2.setCondition(cond);
				}
				bos = ObjectQueryServiceDelegate.getInstance().findBTMObjects(qt2);
			}
			catch(VCIError vcie)
			{
				throw vcie;
			}
			catch(java.lang.Exception se)
			{
				VCIError vcierror = new VCIError("",new String[]{se.getMessage()});
				throw vcierror;
			}
			return bos;
	}
	
	/**
	 * 自定义查询模板，根据查询条件查询符合条件的业务对象和链接类型查询结果
	 * @param linkName，link名称
	 * @param clauseList，返回的字段列表，暂时默认支持*
	 * @param queryISLeaf，是否查询叶子节点，true代表查询，false代表不查询
	 * @param rightFlag，是否根据数据授权过滤，true：进行数据授权过滤，false：不进行数据授权过滤
	 * @param direction，查询方向，true代表正向查询，false代表反向查询
	 * @param queryCondition，是否查询子业务类型的数据
	 * @param version，1：当前版本当前版次；2代表当前版本最新版次；3：代表最新版本最新版次；4代表当前发布有效版
	 * @param pageInfo，分页信息，不需要分页时将其设为null即可，其包含两个属性：pageNO：页数和rowCount：当前页显示条数
	 * @param level，查询的层级，-1代表所有，其他数字代码查询的具体层数
	 * @param orderInfoList，排序信息，不需要是将其设置为null， 其包含三个属性：level:排序优先级，数越小越优先； orderField：排序字段名称;orderMode：属性ASC或DESC;
	 * @param recReturnMode，是否去重，true代表去重，false代表不去重
	 * @param objId，源对象ID
	 * @param btmType，查询目标对象的业务类型
	 * @return
	 * @throws VCIError
	 */
	@Override
	public BOAndLO[] getBOLOsByCondition(String linkName, List<String> clauseList, boolean queryISLeaf, boolean rightFlag, boolean direction,
			Map<String, String> queryCondition, int version, PageInfo pageInfo, int level, List<OrderInfo> orderInfoList, boolean recReturnMode, String objId, String btmType) throws VCIError {
		BOAndLO[]  bolos = null;
		try
		{
		QueryTemplate qt2 = new QueryTemplate();
		qt2.setId("ltQuery");
		qt2.setLinkType(linkName);
		qt2.setType("link");
		clauseList = new ArrayList<String>();
		clauseList.add("*");
		qt2.setClauseList(clauseList);
		qt2.setQueryISLeaf(queryISLeaf);
		qt2.setRightFlag(rightFlag);
		
		if(direction){
			qt2.setDirection(QTConstants.DIRECTION_POSITIVE);
		}else{
			qt2.setDirection(QTConstants.DIRECTION_OPPOSITE);
		}
		if (pageInfo != null && pageInfo.getPageNO() > 0 && pageInfo.getRowCount() > 0) {
			qt2.setPageInfo(pageInfo);
		}
		if (orderInfoList != null && orderInfoList.size() > 0) {
			qt2.setOrderInfoList(orderInfoList);
		}
		if (queryCondition != null && queryCondition.size() > 0) {
			Condition cond = OQueryHelper.getConditionForLink(qt2.getDirection(), objId, btmType, queryCondition);
			qt2.setCondition(cond);
		}
		
		qt2.setVersion(version);
		qt2.setPageInfo(pageInfo);
		qt2.setLevel(level);
		if (recReturnMode) {
			qt2.setRecReturnMode(1);
		} else {
			qt2.setRecReturnMode(2);
		}
		
		bolos = ObjectQueryServiceDelegate.getInstance().getBOAndLOS(qt2, "");
		}
		catch(VCIError vcie)
		{
			throw vcie;
		}
		catch(java.lang.Exception se)
		{
			VCIError vcierror = new VCIError("",new String[]{se.getMessage()});
			throw vcierror;
		}
		return bolos;
	}
}