package com.vci.server.omd.common;

import java.util.ArrayList;
import java.util.List;
import org.dom4j.Element;

import com.vci.corba.common.VCIError;
import com.vci.corba.omd.lcm.Bound;
import com.vci.corba.omd.lcm.LifeCycle;
import com.vci.corba.omd.lcm.LifeCycleService;
import com.vci.corba.omd.lcm.TransitionVO;
import com.vci.corba.omd.lcm.TransitionVOEvent;
import com.vci.server.cache.OMCacheProvider;
import com.vci.server.omd.lifecycle.LifeCycleServiceImpl;

public class LifeCycleHelper {
	private static LifeCycleService lifeCycleService = null;
	
	private static LifeCycleHelper instance = null;
//	public static DateFormat tsDF = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
//	public static DateFormat timeDF = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//	public static final String OID = "oid";
//	public static final String NAME = "name";
//	public static final String LABEL = "label";
//	public static final String DESCRIPTION = "description";
//	public static final String TS = "ts";
//	public static final String CREATOR = "creator";
//	public static final String CREATETIME = "createTime";
//	public static final String MODIFIER = "modifier";
//	public static final String MODIFYTIME = "modifyTime";
	/**
	 * 缓存已经调用new LifeCycleProvider();
	 * 因此不能定义 私有的LifeCycleProvider();
	 * @return
	 */
	public static LifeCycleHelper getInstance(){
		if(instance == null){
			instance = new LifeCycleHelper();
		}
		return instance;
	}
	/***
	 * 
	 *  获取所有链接类型对象数组
	 *  
	 */
	public LifeCycle [] getLifeCyles(){
		return OMCacheProvider.getLifeCycles();
//		LifeCycle[] lifeCyles = null;
//		try {
//			lifeCyles = getService().getLifeCycles(null);
//		} catch (VCIError e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		}
//		return lifeCyles;
	}
    
	public LifeCycle getLifeCycleByName(String name){
		return OMCacheProvider.getLifeCycle(name);
//		LifeCycle[] lcs = null;
//		try {
//			lcs = getService().getLifeCycles(null);
//			
//			for (LifeCycle lc : lcs){
//				if (lc.name.equals(name))
//					return lc; 
//			}
//		} catch (VCIError e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		}
//		return null;
	}
	
//	public LifeCycleService getService(){
//		try {
//			lifeCycleService = new LifeCycleServiceImpl();
//		} catch (Exception e) {
//			e.printStackTrace();
//		}
//		return lifeCycleService;
//	}
	
	public List<String> parseArrayToList(String[] array){
		List<String> list = new ArrayList<String>(array.length);
		for(String a : array){
			list.add(a);
		}
		return list;
	}
//	
//	public boolean expData(String dir, LifeCyle[] lcs){
//		Set<String> spNames = new HashSet<String>();
//		BufferedWriter bw = null;
//		FileOutputStream fos = null;
//		OutputStreamWriter osw =null;
//		try{
//			File file = new File(dir + "/lc.txt");
//			//将clob字段写到单独的文件中
//			new File(dir + "/lc").mkdir();
//			//add by caill start 2015.12.23 	导出时将txt文件设置为“utf-8”格式
//			fos = new FileOutputStream(file);
//			osw = new OutputStreamWriter(fos, "utf-8");
//			bw = new BufferedWriter(osw);
//			//add by caill end
//			/*w = new FileWriter(file);
//			bw = new BufferedWriter(w);*/
//			for(LifeCyle lc : lcs){
//				for(Bound b : lc.bounds){
//					spNames.add(b.name);
//				}
//				//若str小于缓冲区大小, 将写到缓冲区; 
//				//若str大于缓冲区大小, 将刷新缓冲区(将缓冲区内容写到底层流), 然后str直接写到底层流.
//				String text = getObjectText(lc);
//				bw.write(text);
//				bw.newLine(); 
//				BufferedWriter clobBW = null;
//				FileOutputStream fo = null;
//				OutputStreamWriter pw =null;
//				try{
//					File clobFile = new File(dir + "/lc/" + lc.oid + ".xml");
//					//add by caill start 2015.12.23 将xml内容和xml文件格式统一
//				    fo = new FileOutputStream(clobFile);
//					pw = new OutputStreamWriter(fo, "utf-8");
//					clobBW = new BufferedWriter(pw);
//					clobBW.write( "<?xml version=\"1.0\" encoding=\"utf-8\" ?>");
//					clobBW.write(getXmlText(lc));
//					clobBW.flush();
//					//add by caill end
//					/*clobW = new FileWriter(clobFile);
//					clobBW = new BufferedWriter(clobW);
//					clobBW.write( "<?xml version=\"1.0\" encoding=\"gb2312\" ?>");//gb2312
//					clobBW.write(getXmlText(lc));
//					clobBW.flush();*/
//				}catch(IOException e2){
//					e2.printStackTrace();
//				}finally{
//					try{
//						if(clobBW != null){
//							fo.close();		//add by caill 2015.12.23 将fo关闭
//							pw.close();		//add by caill 2015.12.23 将pw关闭
//							clobBW.close();
//						}
//					} catch (IOException e) {
//						e.printStackTrace();
//					}
//				}
//			}
//			bw.flush();
//			List<StatePool> sps = new ArrayList<StatePool>();
//			for(String name : spNames){
//				StatePool sp = StateHelper.getInstance().getService().getStatePool(name);
//				sps.add(sp);
//			}
//			boolean spFlag = StateHelper.getInstance().expData(dir, sps.toArray(new StatePool[0]));
//			if(true & spFlag){
//				System.out.println("**************生命周期导出成功************");
//			}else{
//				System.out.println("**************生命周期导出失败************");
//			}
//			
//			return true & spFlag;
//		}catch(IOException e){
//			e.printStackTrace();
//		} catch (VCIError e) {
//			e.printStackTrace();
//		}finally{
//			try {
//				if(bw != null){
//					fos.close();		//add by caill 2015.12.23 将fos关闭
//					osw.close();		//add by caill 2015.12.23 将osw关闭
//					bw.close();
//				}
//			} catch (IOException e) {
//				e.printStackTrace();
//			}
//		}
//		return false;
//	}
//	
//	/**
//	 * 将对象转化成字符串
//	 * {oid:qqq, name:q}
//	 * @param lc
//	 * @return
//	 */
//	public String getObjectText(LifeCyle lc) {
//		StringBuilder stb = new StringBuilder("{");
//		stb.append(OmdConstants.OID + ":" + lc.oid + ",");
//		stb.append(OmdConstants.NAME + ":" + lc.name + ",");
//		stb.append(OmdConstants.LABEL + ":" + lc.tag + ",");
//		stb.append(OmdConstants.DESCRIPTION + ":" + lc.description + ",");
//		stb.append(OmdConstants.TS + ":" + lc.ts + ",");
//		stb.append(OmdConstants.CREATOR + ":" + lc.creator + ",");
//		stb.append(OmdConstants.CREATETIME + ":" + lc.createTime + ",");
//		stb.append(OmdConstants.MODIFIER + ":" + lc.modifier + ",");
//		stb.append(OmdConstants.MODIFYTIME + ":" + lc.modifyTime);
//		stb.append("}");
//		return stb.toString();
//	}
	
	/**
	 * 将LifeCyle转化成xmltext
	 * @param bt
	 * @return
	 */
	public String getXmlText(LifeCycle lc){
		StringBuilder stb = new StringBuilder("<LifeCyle>");
		stb.append("<name>" + lc.name + "</name>");
		stb.append("<tag>" + lc.tag + "</tag>");
		stb.append("<description>" + lc.description + "</description>");
		stb.append("<startState>" + lc.startState + "</startState>");
		for(Bound b : lc.bounds){
			stb.append("<bound>");
			stb.append("<name>" + b.name + "</name>");
			stb.append("<cellx>" + b.cellx + "</cellx>");
			stb.append("<celly>" + b.celly + "</celly>");
			stb.append("<cellw>" + b.cellw + "</cellw>");
			stb.append("<cellh>" + b.cellh + "</cellh>");
			stb.append("<cellicon>" + b.cellicon + "</cellicon>");
			stb.append("</bound>");
		}
		
		for(TransitionVO t : lc.routes){
			stb.append("<transitionVO>");
			stb.append("<source>" + t.source + "</source>");
			stb.append("<destination>" + t.destination + "</destination>");
			stb.append("<connect>" + t.connect + "</connect>");
			for(TransitionVOEvent te : t.transitionVOEvents){
				stb.append("<transitionVOEvent>");
				stb.append("<id>" + te.id + "</id>");
				stb.append("<name>" + te.name + "</name>");
				stb.append("</transitionVOEvent>");
			}
			stb.append("</transitionVO>");
		}
		stb.append("</LifeCyle>");
		return stb.toString();
	}
//	
//	public List<LifeCyle> getLCFromFile(String dir) {
//		File file = new File(dir + "/lc.txt");
//		List<LifeCyle> list = new ArrayList<LifeCyle>();
//		BufferedReader br = null;
//		FileInputStream fo = null;
//		InputStreamReader isw =null;
//		try {
//			/*r = new FileReader(file);
//			br = new BufferedReader(r);*/
//			//add by caill start 2015.12.23 	导入时将txt文件内容设置为“utf-8”格式
//		    fo = new FileInputStream(file);
//			isw = new InputStreamReader(fo, "utf-8");
//			br = new BufferedReader(isw);
//			//add by caill end
//			String str = null;
//			while((str = br.readLine()) != null){
//				Map<String, String> map = getMapFormText(str);
//				String oid = map.get("oid");
//				if(oid != null && !oid.equals("")){
//					File contentFile = new File(dir + "/lc/" + oid + ".xml");
//					if(!contentFile.exists()){
//						System.out.println(dir + "/lc/" + oid + ".xml不存在");
//						break;
//					}
//					LifeCyle lc = new LifeCyle();
//					lc.oid = oid;
//					lc.name = map.get("name");
//					lc.tag = map.get("label");
//					lc.description = map.get("description");
//					lc.ts = map.get("ts");
//					lc.creator = map.get("creator");
//					lc.createTime = map.get("createTime");
//					lc.modifier = map.get("modifier");
//					lc.modifyTime = map.get("modifyTime");
//					SAXReader sa = new SAXReader();
//					//add by caill 2015.12.23	导入时将saxReader对象设置为“utf-8”格式
//					sa.setEncoding("utf-8");
//					Document document = sa.read(contentFile);
//					setLCValueFormDoc(lc, document.getRootElement());
//					list.add(lc);
//				}else{
//					System.out.println(dir + "lc.txt中存在oid为空的错误记录");
//					break;
//				}
//			}
//			return list;
//		} catch (FileNotFoundException e) {
//			e.printStackTrace();
//		} catch (IOException e) {
//			e.printStackTrace();
//		} catch (DocumentException e) {
//			e.printStackTrace();
//		} finally{
//			if(br != null){
//				try {
//					fo.close();		//add by caill 2015.12.16	将fo关闭
//					isw.close();	//add by caill 2015.12.16	将isw关闭
//					br.close();
//				} catch (IOException e) {
//					e.printStackTrace();
//				}
//			}
//		}
//		return null;
//	}
//	/**
//	 * 将文件中一条记录解析成key-value
//	 * @param str
//	 * @return
//	 */
//	public Map<String, String> getMapFormText(String str) {
//		str = str.trim();
//		if(!str.startsWith("{") || !str.endsWith("}")){
//			return null;
//		}
//		Map<String, String> map = new HashMap<String, String>();
//		str = str.substring(1, str.length() - 1);
//		String[] kvs = str.split(",");
//		for(String kv : kvs){
//			String[] kv_ = kv.split(":");
//			if(kv_.length == 1){
//				map.put(kv_[0].trim(), "");	
//			}else{
//				map.put(kv_[0].trim(), kv_[1].trim());
//			}
//		}
//		return map;
//	}
//	
	/**
	 * 设置EnumItem存在
	 * @param lc
	 * @param element
	 */
	public void setLCValueFormDoc(LifeCycle lc, Element element){
		String value = element.elementText("startState");
		lc.startState = (value == null ? "" : value);
		List<Element> bElements = element.elements("bound");
		List<Bound> bs = new ArrayList<Bound>();
		for(Element bElement : bElements){
			Bound b = new Bound();
			value = bElement.elementText("name");
			b.name = (value == null ? "" : value);
			value = bElement.elementText("cellx");
			b.cellx = (value == null ? "" : value);
			value = bElement.elementText("celly");
			b.celly = (value == null ? "" : value);
			value = bElement.elementText("cellw");
			b.cellw = (value == null ? "" : value);
			value = bElement.elementText("cellh");
			b.cellh = (value == null ? "" : value);
			value = bElement.elementText("cellicon");
			b.cellicon = (value == null ? "" : value);
			bs.add(b);
		}
		lc.bounds = bs.toArray(new Bound[0]);
		
		List<Element> tElements = element.elements("transitionVO");
		List<TransitionVO> ts = new ArrayList<TransitionVO>();
		for(Element tElement : tElements){
			TransitionVO t = new TransitionVO();
			value = tElement.elementText("source");
			t.source = (value == null ? "" : value);
			value = tElement.elementText("destination");
			t.destination = (value == null ? "" : value);
			value = tElement.elementText("connect");
			t.connect = (value == null ? "" : value);
			List<Element> teElements = tElement.elements("transitionVOEvent");
			List<TransitionVOEvent> tes = new ArrayList<TransitionVOEvent>();
			for(Element teElement : teElements){
				TransitionVOEvent te = new TransitionVOEvent();
				value = teElement.elementText("id");
				te.id = value;
				value = teElement.elementText("name");
				te.name = value;
				tes.add(te);
			}
			t.transitionVOEvents = tes.toArray(new TransitionVOEvent[0]);
			ts.add(t);
		}
		lc.routes = ts.toArray(new TransitionVO[0]);
	}
//	
//	public boolean impData(String dir, LifeCyle[] lcs) {
//		try {
//			List<StatePool> sps = StateHelper.getInstance().getSPFromFile(dir);
//			boolean spFlag = StateHelper.getInstance().impData(sps.toArray(new StatePool[0]));
//			if(!spFlag){
//				System.out.println("生命周期使用的状态池导入失败。导入中止。");
//				return false;
//			}
//			for(LifeCyle lc : lcs){
//				LifeCyle lc_ = getService().getLifeCycle(lc.name);
//				//已经存在
//				if(!lc_.oid.equals("")){
//					//覆盖
//					getService().deleteLifeCyle(lc_);
//					getService().addLifeCyle(lc);
//					System.out.println(lc.name + "在数据库中已经存在， 覆盖。");
//				}else{
//					getService().addLifeCyle(lc);
//				}
//			}
//			return true;
//		} catch (VCIError e) {
//			e.printStackTrace();
//		}
//		return false;
//	}
}