package com.vci.client.refquery;

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

import com.vci.client.ui.exception.VCIException;
import com.vci.client.common.ClientLog4j;
import com.vci.client.common.providers.ServiceProvider;
import com.vci.corba.common.VCIError;
import com.vci.corba.query.ObjectQueryServicePrx;
import com.vci.corba.query.data.RefPath;
import com.vci.corba.query.data.RefValue;

public class PLMReferenceQueryFacade {
	private static ObjectQueryServicePrx refService = null;
	private RefPath[] clientRefpaths = null;

	public ObjectQueryServicePrx getRefServer() throws VCIException {
		if (refService != null) {
			return refService;
		}
		try {

			return refService = ServiceProvider.getOQService();
		} catch (Exception e) {
			ClientLog4j.logger.error(e.getMessage(), e);
			throw new VCIException("1", new String[] { e.getMessage() });
		}
	}

	/**
	 * @param String
	 *            [] 参照属性路径信息（ referenceDatas）: e.g , ( String[] referenceDatas
	 *            = new String[] {
	 *            "btd.gg=22385E82-485C-549D-E2F4-91278E9E0A78,22385E82-485C-549D-E2F4-91278E9E0A75"
	 *            ,
	 *            "btd.gg.name=22385E82-485C-549D-E2F4-91278E9E0A78,22385E82-485C-549D-E2F4-91278E9E0A75"
	 *            ,
	 *            "btd.gg.ddd.name=22385E82-485C-549D-E2F4-91278E9E0A78,22385E82-485C-549D-E2F4-91278E9E0A75"
	 *            ,
	 *            "btd.gg.gg.name=22385E82-485C-549D-E2F4-91278E9E0A78,22385E82-485C-549D-E2F4-91278E9E0A75"
	 *            ,
	 *            "btd.gg.gg.gg.name=22385E82-485C-549D-E2F4-91278E9E0A78,22385E82-485C-549D-E2F4-91278E9E0A75"
	 *            ,
	 *            "btd.gg.gg.gg.ddd.name=22385E82-485C-549D-E2F4-91278E9E0A78,22385E82-485C-549D-E2F4-91278E9E0A75"
	 *            ,
	 *            "btd.gg.gg.gg.ddd.gg.name=22385E82-485C-549D-E2F4-91278E9E0A78,22385E82-485C-549D-E2F4-91278E9E0A75"
	 *            , "btd.ddd=22385E82-485C-549D-E2F4-91278E9E0A78",
	 *            "btd.ddd.ddd.gg.name=22385E82-485C-549D-E2F4-91278E9E0A78" };)
	 * @param String
	 *            参照属性与标识的分隔符 （split） : e.g,( "=")
	 * @param String
	 *            标识的分隔符 （idSplit） : e.g, (",")
	 * @return RefPath[] 参照信息值对象
	 * 
	 * */
	public RefPath[] toRefPath(String[] referenceDatas, String split,
			String idSplit) {
		RefPath[] referencePaths = new RefPath[referenceDatas.length];
		RefPath[] referencePathsForCorba = new RefPath[referenceDatas.length];
		for (int i = referenceDatas.length - 1; i >= 0; i--) {
			String rPath = referenceDatas[i];
			String[] rBelongsIds = rPath.split(split);
			RefPath referencePath = new RefPath();
			RefPath referencePathForCorba = new RefPath();
			// path
			referencePath.path = rBelongsIds[0];
			referencePathForCorba.path = rBelongsIds[0];
			if (rBelongsIds != null && rBelongsIds.length > 1) {

				String id = rBelongsIds[1];
				String[] ids = id.split(idSplit);
				RefValue[] values = new RefValue[ids.length];
				List<RefValue> valuesForCorba = new ArrayList<RefValue>();
				for (int m = 0; m < ids.length; m++) {
					RefValue value = new RefValue();
					value.row = m;
					value.value = ids[m];
					values[m] = value;
					if (isContained(valuesForCorba, ids[m])) {
						continue;
					}
					valuesForCorba.add(value);
				}
				referencePathForCorba.values = valuesForCorba
						.toArray(new RefValue[valuesForCorba.size()]);
				referencePath.values = values;
			}
			referencePaths[i] = referencePath;
			referencePathsForCorba[i] = referencePathForCorba;
		}
		clientRefpaths = referencePaths;
		return referencePathsForCorba;

	}

	private boolean isContained(List<RefValue> values, String id) {

		for (RefValue v : values) {
			if (null != v && v.value.equals(id)) {
				return true;
			}
		}
		return false;

	}

	private int knowPathIndex(String path, RefPath[] returnPaths) {
		int dbIndex = 0;
		for (int i = 0; i < returnPaths.length; i++) {
			if (returnPaths[i].path.equals(path)) {
				dbIndex = i;
				break;
			}

		}
		return dbIndex;
	}

	private int knowValueIndex(String oid, RefValue[] dbvalues) {
		int dbIndex = 0;
		for (int i = 0; i < dbvalues.length; i++) {
			if (dbvalues[i].value.equals(oid)) {
				dbIndex = i;
				break;
			}

		}
		return dbIndex;
	}

	private void copy(RefPath[] returnPaths) {
		for (int m = 0; m < clientRefpaths.length; m++) {
			RefValue[] values = clientRefpaths[m].values;
			String path = clientRefpaths[m].path;
			String[] rootpaths = path.split("\\.");
			String root = rootpaths[0] + "." + rootpaths[1];
			int dbIndex = knowPathIndex(path, returnPaths);
			int dbrootIndex = knowPathIndex(root, returnPaths);
			RefValue[] dbvalues = returnPaths[dbIndex].values;
			RefValue[] rootdbvalues = returnPaths[dbrootIndex].values;
			for (int n = 0; n < values.length; n++) {
				String oid = values[n].value;
				int valueindex = knowValueIndex(oid, rootdbvalues);
				values[n].value = dbvalues[valueindex].value;

			}
		}
	}

	public RefPath[] query(String[] references, String toType)
			throws VCIException, VCIError {
		ObjectQueryServicePrx server = getRefServer();
		RefPath[] referencePaths = this.toRefPath(references, "=", ",");
		RefPath[] returnPaths = server.getRefResults(referencePaths, toType);
		copy(returnPaths);
		return this.clientRefpaths;
	}
	
	public RefPath[] query(String[] references, String[] toTypes)
			throws VCIException, VCIError {
		ObjectQueryServicePrx server = getRefServer();
		RefPath[] referencePaths = this.toRefPath(references, "=", ",");
		RefPath[] returnPaths = server.getRefTypesResults(referencePaths, toTypes);
		copy(returnPaths);
		return this.clientRefpaths;
	}

	public RefPath[] query(String[] references) throws VCIException, VCIError {
		ObjectQueryServicePrx server = getRefServer();
		RefPath[] referencePaths = this.toRefPath(references, "=", ",");
		long From = System.currentTimeMillis();
		RefPath[] returnPaths = server.getRefQueryResults(referencePaths);
		long to = System.currentTimeMillis();
		copy(returnPaths);
		System.out.println("time cost: " + (to - From) + " ms");
		ClientLog4j.logger.debug("time cost: " + (to - From) + " ms");
		return this.clientRefpaths;
	}

	public static void main(String[] s) {
		// String two =
		// "e33666f6-db15-44e9-b0a2-7ca2b001c5f6,7D6FEE4E-91DF-CDF8-A735-6DE3E39157A1";
		// // for (int i = 0; i < 10000; i++) {
		// // //two += "," + UUID.randomUUID();
		// // }
		// String[] referenceDatas = new String[] { "bta.gg=" +
		// two,"bta.gg.t_oid="+two,
		// "bta.gg.t_oid.gg.t_oid=" + two, "bta.gg.t_oid.name=" + two,
		// "bta.gg.t_oid.ddd.name=" + two, "bta.gg.t_oid.ddd=" + two,
		// "bta.gg.t_oid.ddd.ddd.name=" + two };
		String refrenceOids = "A5374FB0-9A14-C053-580E-0E8C36A42DA7,DBA8483C-4DA7-90ED-2DA7-00DC27E19B09,8D86B310-B128-1DDE-03E7-937251F55E7A,BB481B13-F2DE-A1E9-ADB7-4014522CA9FC,FEEEED35-FD6E-E0CC-2059-A4B5A422CFE8,3B471AF4-07C7-85BA-5C36-494DCE759F7B";
		String[] referenceDatas = new String[] {
//				"processcitem.sprocedure=E47ED10F-2897-DB55-C549-114E360ACFCA",
//				"processcitem.sprocedure.processno=E47ED10F-2897-DB55-C549-114E360ACFCA",
//				"processcitem.sprocedure.content=E47ED10F-2897-DB55-C549-114E360ACFCA",
//				"processcitem.sprocedure.equipment=E47ED10F-2897-DB55-C549-114E360ACFCA"
//				"processcitem.sprocedure.workcenter=E47ED10F-2897-DB55-C549-114E360ACFCA"
//				"processcitem.ownedchangeorder=794DC0F7-248A-436D-DB6D-0998C3DCF511",
//				"processcitem.ownedchangeorder.name=794DC0F7-248A-436D-DB6D-0998C3DCF511",
//				"processcitem.usedbypart=37EDEC00-F3A6-A4D5-23E7-D06846FAB51D",
//				"processcitem.usedbypart.code=37EDEC00-F3A6-A4D5-23E7-D06846FAB51D",
//				"processcitem.usedbypart.id=37EDEC00-F3A6-A4D5-23E7-D06846FAB51D",
//				"processcitem.usedbypart.name=37EDEC00-F3A6-A4D5-23E7-D06846FAB51D"
//				"processcitem.eprocedure=754AFD8C-0203-B351-0C19-B6E29EB63044",
//				"processcitem.eprocedure.processno=754AFD8C-0203-B351-0C19-B6E29EB63044",
//				"processcitem.eprocedure.content=754AFD8C-0203-B351-0C19-B6E29EB63044",
//				"processcitem.eprocedure.equipment=754AFD8C-0203-B351-0C19-B6E29EB63044",
//				"processcitem.eprocedure.workcenter=754AFD8C-0203-B351-0C19-B6E29EB63044",
//				"processcitem.ownedprocess=3B747DC0-7FD0-868A-951E-6C89197B289E",
//				"processcitem.ownedprocess.code=3B747DC0-7FD0-868A-951E-6C89197B289E",
//				"processcitem.ownedprocess.name=3B747DC0-7FD0-868A-951E-6C89197B289E",
//				"processcitem.ownedprocess.ownedppr=3B747DC0-7FD0-868A-951E-6C89197B289E",
//				"processcitem.ownedprocess.ownedppr.routecontent=3B747DC0-7FD0-868A-951E-6C89197B289E",
//				"processcitem.ownedprocess.pprnode=3B747DC0-7FD0-868A-951E-6C89197B289E",
//				"processcitem.ownedprocess.pprnodeposition=3B747DC0-7FD0-868A-951E-6C89197B289E"
//				"input.t_oid=00EC4767-6DAE-C3A3-CD9A-33C832B59636,F2033E00-8D2B-9BDF-2180-17937A2F4FDA,DBEF3A01-381A-8BA8-E4BA-1DE6598294E9",
//				"input.t_oid.usedbyppart.code=00EC4767-6DAE-C3A3-CD9A-33C832B59636,F2033E00-8D2B-9BDF-2180-17937A2F4FDA,DBEF3A01-381A-8BA8-E4BA-1DE6598294E9",
//				"input.t_oid.id=00EC4767-6DAE-C3A3-CD9A-33C832B59636,F2033E00-8D2B-9BDF-2180-17937A2F4FDA,DBEF3A01-381A-8BA8-E4BA-1DE6598294E9"
//				"groupprocessroute.usedbyppart=BB35180E-6C4D-BA95-1A2B-A9D4013A9BA0,D460C91D-527F-0BAF-5E35-F3944DA2B58A",
//				"groupprocessroute.usedbyppart.code=D460C91D-527F-0BAF-5E35-F3944DA2B58A,D460C91D-527F-0BAF-5E35-F3944DA2B58A"
				"input.t_oid=57CBC8E1-16CC-C603-0BC1-425A782E7223",
				"input.t_oid.usedbyppart=57CBC8E1-16CC-C603-0BC1-425A782E7223",
				"input.t_oid.abcdef=57CBC8E1-16CC-C603-0BC1-425A782E7223",
				"input.t_oid.usedbyppart.id=57CBC8E1-16CC-C603-0BC1-425A782E7223",
				"input.t_oid.usedbyppart.name=57CBC8E1-16CC-C603-0BC1-425A782E7223"
				};
		
		String[] types = new String[]{
				"groupprocessroute",
				"groupprocessroute",
				"product"
		};
		
		String type = "plantprocessroute";

		PLMReferenceQueryFacade facade = new PLMReferenceQueryFacade();
		try {
			@SuppressWarnings("unused")
			RefPath[] results = facade.query(referenceDatas, type);
//			RefPath[] results = facade.query(referenceDatas);
			System.out.println();
		} catch (VCIException e) {
			e.printStackTrace();
		} catch (VCIError e) {
			e.printStackTrace();
		}

	}
}