package com.vci.test.oq;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.Callable;

import com.vci.client.common.oq.OQTool;
import com.vci.client.common.providers.ServiceProvider;
import com.vci.client.oq.QTClient;
import com.vci.client.oq.QTDClient;
import com.vci.common.qt.object.ChildrenInfo;
import com.vci.common.qt.object.Condition;
import com.vci.common.qt.object.ConditionItem;
import com.vci.common.qt.object.Connector;
import com.vci.common.qt.object.LeafInfo;
import com.vci.common.qt.object.LeafValue;
import com.vci.common.qt.object.Operator;
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.common.qt.object.Version;
import com.vci.corba.common.VCIError;
import com.vci.corba.omd.data.BusinessObject;
import com.vci.corba.omd.data.LinkObject;
import com.vci.corba.query.data.BOAndLO;

public class Test{
	
	@org.junit.Test
	public void getQT() throws VCIError{
		boolean qt = ServiceProvider.getOMDService().getQTDService().isExistsQT("GroupPRunitQueryAll");
		System.out.println();
	}
	@org.junit.Test
	public void buildWholeQT(){
		QueryTemplate qt = new QueryTemplate();
		qt.setId("queryLink");
		qt.setType("link");
		qt.setLinkType("DocumentRelation");
		qt.setBtmType("Document");
		List<String> clauseList = new ArrayList<String>();
		clauseList.add("*");
		qt.setClauseList(clauseList);
		PageInfo pageInfo = new PageInfo();
		pageInfo.setPageNO(1);
		pageInfo.setRowCount(100);
		qt.setPageInfo(pageInfo);
		qt.setVersion(Version.currentRevLastVer);
		qt.setDirection("positive");
		qt.setLevel(1);
		List<OrderInfo> orderInfoList = new ArrayList<OrderInfo>();
		OrderInfo e = new OrderInfo();
		e.setLevel(2);
		e.setOrderField("linkAttr1");
		e.setOrderMode(QTConstants.ORDERMODE_DESC);
		orderInfoList.add(e );
		OrderInfo e2 = new OrderInfo();
		e2.setLevel(5);
		e2.setOrderField("T_OID.btmAttr1");
		e2.setOrderMode(QTConstants.ORDERMODE_ASC);
		orderInfoList.add(e2 );
		qt.setOrderInfoList(orderInfoList );
		Condition condition = new Condition();
		condition.setRootCIName("ci3");
		Map<String, ConditionItem> cIMap = new HashMap<String, ConditionItem>();
		condition.setCIMap(cIMap );
		ConditionItem ci1 = new ConditionItem();
		ci1.setId("ci1");
		ci1.setLeafFlag(true);
		LeafInfo leafInfo = new LeafInfo();
		leafInfo.setClause("linkAttr2");
		leafInfo.setOperator(Operator.EQUAL);
		LeafValue value = new LeafValue();
		value.setOrdinaryValue("abc");
		leafInfo.setValue(value );
		ci1.setLeafInfo(leafInfo );
		ConditionItem ci2 = new ConditionItem();
		ci2.setId("ci2");
		ci2.setLeafFlag(true);
		LeafInfo leafInfo_ = new LeafInfo();
		leafInfo_.setClause("T_OID.btmAttr2");
		leafInfo_.setOperator(Operator.IN);
		LeafValue value_ = new LeafValue();
			QueryTemplate refQt = new QueryTemplate();
			refQt.setId("queryBtm");
			refQt.setType("btm");
			refQt.setBtmType("Document");
			refQt.setVersion(3);
			List<String> clauseList_ = new ArrayList<String>();
			clauseList_.add("btmAttr2");
			refQt.setClauseList(clauseList_);
			Condition condition_ = new Condition();
			condition_.setRootCIName("ci1_");
			Map<String, ConditionItem> cIMap_ = new HashMap<String, ConditionItem>();
			condition_.setCIMap(cIMap_ );
			ConditionItem ci1_ = new ConditionItem();
			cIMap_.put("ci1_", ci1_ );
			ci1_.setId("ci1_");
			ci1_.setLeafFlag(true);
			LeafInfo _leafInfo = new LeafInfo();
			_leafInfo.setClause("btmAttr3");
			_leafInfo.setOperator(Operator.LIKE);
			LeafValue _value = new LeafValue();
			_value.setOrdinaryValue("abc");
			_leafInfo.setValue(_value );
			ci1_.setLeafInfo(_leafInfo );
			refQt.setCondition(condition_);
		value_.setQueryTemplate(refQt );
		leafInfo_.setValue(value_ );
		ci2.setLeafInfo(leafInfo_ );
		cIMap.put("ci1", ci1);
		cIMap.put("ci2", ci2);
		ConditionItem ci3 = new ConditionItem();
		ci3.setId("ci3");
		ci3.setLeafFlag(false);
		ChildrenInfo childrenInfo = new ChildrenInfo();
		childrenInfo.setConnector(Connector.AND);
		childrenInfo.setLeftCIName("ci1");
		childrenInfo.setRightCIName("ci2");
		ci3.setChildrenInfo(childrenInfo );
		cIMap.put("ci3", ci3 );
		qt.setCondition(condition);
		
		String asXML = OQTool.qtTOXMl(qt).asXML();
		System.out.println();
	}
	
	public static void main(String[] args){
		int i;
		for(i = 0; i < 1; i++){
			Thread t = new Thread(new RunnableTest());
			t.setName("thread-" + i);
			t.start();
		}
		QueryTemplate qt = new QueryTemplate();
		qt.setId("queryBtm");
		qt.setType(QTConstants.TYPE_BTM);
		qt.setBtmType("part");
		List<String> clauseList = new ArrayList<String>();
		clauseList.add("*");
		qt.setClauseList(clauseList);
		qt.setVersion(Version.lastReleasedRev);
		
		Map<String, String> map = new HashMap<String, String>();
		map.put("nameoid", "6AF73192-2B0C-FFF5-2B76-9819C44E566F");
		Condition condition = OQTool.getCondition(map );
		qt.setCondition(condition);
		
		BusinessObject[] bts = null;
		long ss = System.currentTimeMillis();
		try {
			bts = QTClient.getService().findBTMObjects(qt.getId(), OQTool.getQTTextByQT(qt));
		} catch (VCIError e) {
			e.printStackTrace();
		}
		long ss2 = System.currentTimeMillis();
		System.out.println("BusinessObject: " + (ss2 - ss) + "-----" + bts.length);
	}
	
//	public static void main(String[] args) throws InterruptedException, ExecutionException, TimeoutException {
//		ExecutorService exec = Executors.newCachedThreadPool();
//		ExecutorCompletionService<BOAndLO[]> completionExec = new ExecutorCompletionService<BOAndLO[]>(exec);
//		List<Future<BOAndLO[]>> list1 = new ArrayList<Future<BOAndLO[]>>();
//		List<Future<BOAndLO[]>> list2 = new ArrayList<Future<BOAndLO[]>>();
//		int i;
//		for (i = 0; i < 10; i++) {
////			list1.add(exec.submit(new CallableTest()));
//			completionExec.submit(new CallableTest());
//		}
////		for(Future<BOAndLO[]> f1 : list1){
////			//如有必要，等待计算完成，然后获取其结果。
////			BOAndLO[] boAndLOs = f1.get(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
////			System.out.println(f1.toString() + ":" + boAndLOs.length);
////		}
//		
//		for(i = 0; i < 10; i++){
//			//completionExec.take():
//			//获取并移除表示下一个已完成任务的 Future，如果目前不存在这样的任务，则等待。
//			//任务完成后调用done(),将完成的任务加入队列；如果队列中没有已经完成的任务，则等待。
//			BOAndLO[] boAndLOs = completionExec.take().get(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
//			System.out.println(i + ":" + boAndLOs.length);
//		}
//		exec.shutdownNow();
//		exec.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
//	}
}

class RunnableTest implements Runnable{

	@Override
	public void run() {
		QueryTemplate qt = new QueryTemplate();
		qt.setId("queryLink");
		qt.setType("link");
		qt.setLinkType("MBOM");
		qt.setBtmType("part");
		qt.setVersion(Version.lastReleasedRev);
		qt.setDirection("positive");
		qt.setRecReturnMode(QTConstants.RECRETURNMODE_FILTER);
		qt.setLevel(10);
		List<String> clauseList = new ArrayList<String>();
		clauseList.add("*");
		qt.setClauseList(clauseList);
		Condition condition = new Condition();
		qt.setCondition(condition);
		condition.setRootCIName("ci1");
		Map<String, ConditionItem> cIMap = new HashMap<String, ConditionItem>();
		condition.setCIMap(cIMap );
		ConditionItem ci1 = new ConditionItem();
		ci1.setId("ci1");
		ci1.setLeafFlag(true);
		LeafInfo leafInfo = new LeafInfo();
		leafInfo.setClause("f_oid");
		leafInfo.setOperator(Operator.EQUAL);
		LeafValue value = new LeafValue();
		value.setOrdinaryValue("E120EECE-733D-F0CE-0465-9DB3BBC7086B");
//		value.setOrdinaryValue("FC9F8F84-0C06-EC51-4089-4A5C60115B81");
		leafInfo.setValue(value );
		ci1.setLeafInfo(leafInfo );
		cIMap.put("ci1", ci1);
		
		ConditionItem ci2 = new ConditionItem();
		ci2.setId("ci2");
		ci2.setLeafFlag(true);
		LeafInfo leafInfo_ = new LeafInfo();
		leafInfo_.setClause("ownedmanuproduct");
		leafInfo_.setOperator(Operator.EQUAL);
		LeafValue value_ = new LeafValue();
		value_.setOrdinaryValue("5F460EF5-7EBE-0A9D-C32D-451C6D343AF1");
		leafInfo_.setValue(value_ );
		ci2.setLeafInfo(leafInfo_ );
		cIMap.put("ci1", ci1);
		cIMap.put("ci2", ci2);
		ConditionItem ci3 = new ConditionItem();
		ci3.setId("ci3");
		ci3.setLeafFlag(false);
		ChildrenInfo childrenInfo = new ChildrenInfo();
		childrenInfo.setConnector(Connector.AND);
		childrenInfo.setLeftCIName("ci1");
		childrenInfo.setRightCIName("ci2");
		ci3.setChildrenInfo(childrenInfo );
		cIMap.put("ci3", ci3 );
		
		long s1 = System.currentTimeMillis();
		LinkObject[] los = null;
		try {
			los = QTClient.getService().findLTObjects(qt.getId(), OQTool.getQTTextByQT(qt));
			System.out.println();
		} catch (VCIError e) {
			e.printStackTrace();
		}
		long s11 = System.currentTimeMillis();
		System.out.println(Thread.currentThread().getName() + "****findLTObjects:" + (s11 - s1) +"--"+ los.length);
//		BOAndLO[] boAndLOS = null;
//		long s2 = System.currentTimeMillis();
//		try {
//			boAndLOS = QTClient.getService().getBOAndLOS(qt.getId(), Tool.getQTTextByQT(qt), "");
//		} catch (VCIError e) {
//			e.printStackTrace();
//		}
//		long s3 = System.currentTimeMillis();
//		System.out.println(Thread.currentThread().getName() + "****BOAndLO:" + (s3 - s2) +"--"+ boAndLOS.length);
	}
}


class CallableTest implements Callable<BOAndLO[]>{

	@Override
	public BOAndLO[] call() throws Exception {
		QueryTemplate qt = new QueryTemplate();
		qt.setId("queryLink");
		qt.setType("link");
		qt.setLinkType("EBOM");
		qt.setBtmType("part,product");
		qt.setVersion(Version.lastReleasedRev);
		qt.setDirection("positive");
		qt.setLevel(10);
		List<String> clauseList = new ArrayList<String>();
		clauseList.add("*");
		qt.setClauseList(clauseList);
		Condition condition = new Condition();
		qt.setCondition(condition);
		condition.setRootCIName("ci1");
		Map<String, ConditionItem> cIMap = new HashMap<String, ConditionItem>();
		condition.setCIMap(cIMap );
		ConditionItem ci1 = new ConditionItem();
		ci1.setId("ci1");
		ci1.setLeafFlag(true);
		LeafInfo leafInfo = new LeafInfo();
		leafInfo.setClause("f_oid");
		leafInfo.setOperator(Operator.EQUAL);
		LeafValue value = new LeafValue();
		value.setOrdinaryValue("E120EECE-733D-F0CE-0465-9DB3BBC7086B");
		leafInfo.setValue(value );
		ci1.setLeafInfo(leafInfo );
		cIMap.put("ci1", ci1);
		
		long s2 = System.currentTimeMillis();
		BOAndLO[] boAndLOS = null;
		try {
			boAndLOS = QTClient.getService().getBOAndLOS(qt.getId(), OQTool.getQTTextByQT(qt), "");
		} catch (VCIError e) {
			e.printStackTrace();
		}
		long s3 = System.currentTimeMillis();
//		System.out.println(Thread.currentThread().getName() + "***BOAndLO:" + (s3 - s2));
		return boAndLOS;
	}
	
}