package com.vci.client.omd.provider;


import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.dom4j.Document;
import org.dom4j.DocumentException;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;

import com.vci.client.common.providers.ServiceProvider;
import com.vci.corba.common.VCIError;
import com.vci.corba.omd.vrm.VersionRule;
import com.vci.corba.omd.vrm.VersionRuleServicePrx;
import com.vci.omd.constants.OmdConstants;

public class VersionRuleProvider {

	private static VersionRuleProvider instance = null;

	/**
	 * 缓存已经调用new VersionRuleProvider();
	 * 因此不能定义 私有的VersionRuleProvider();
	 * @return
	 */
	public static VersionRuleProvider getInstance(){
		if(instance == null){
			instance = new VersionRuleProvider();
		}
		return instance;
	}
	
	/***
	 * 
	 *  获取所有链接类型对象数组
	 *  
	 */
	public VersionRule [] getVersionRules(){
		VersionRule[] versionRules = null;
		try {
			versionRules = getService().getVersionRules();
		} catch (VCIError e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return versionRules;
	}
	
	public VersionRule getVersionRuleByName(String name){

		try {
			VersionRule[] vrs = getService().getVersionRules();
			for(VersionRule vr : vrs){
				if (vr.name.equals(name))
					return vr;
			}
		} catch (VCIError e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return null;
	}

	
	public VersionRuleServicePrx getService(){
		try {
			return ServiceProvider.getOMDService().getVerRuleService();
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}

	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, VersionRule[] vrs){
		//TODO调用ATT, LC, VR的导出
		BufferedWriter bw = null;
		FileOutputStream fos = null;
		OutputStreamWriter osw =null;
		try{
			File file = new File(dir + "/vr.txt");
			//将clob字段写到单独的文件中
			new File(dir + "/vr").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(VersionRule vr : vrs){
				//若str小于缓冲区大小, 将写到缓冲区; 
				//若str大于缓冲区大小, 将刷新缓冲区(将缓冲区内容写到底层流), 然后str直接写到底层流.
				String text = getObjectText(vr);
				bw.write(text);
				bw.newLine();
				BufferedWriter clobBW = null;
				FileOutputStream fo = null;
				OutputStreamWriter pw =null;
				try{
					File clobFile = new File(dir + "/vr/" + vr.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(vr));
					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(vr));
					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();
			System.out.println("**************版本规则导出成功************");
			return true;
		}catch(IOException 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();
			}
		}
		System.out.println("**************版本规则导出失败************");
		return false;
	}
	
	/**
	 * 将对象转化成字符串
	 * {oid:qqq, name:q}
	 * @param vr
	 * @return
	 */
	public String getObjectText(VersionRule vr) {
		StringBuilder stb = new StringBuilder("{");
		stb.append(OmdConstants.OID + ":" + vr.oid + ",");
		stb.append(OmdConstants.NAME + ":" + vr.name + ",");
		stb.append(OmdConstants.LABEL + ":" + vr.tag + ",");
		stb.append(OmdConstants.DESCRIPTION + ":" + vr.description + ",");
		stb.append(OmdConstants.TS + ":" + vr.ts + ",");
		stb.append(OmdConstants.CREATOR + ":" + vr.creator + ",");
		stb.append(OmdConstants.CREATETIME + ":" + vr.createTime + ",");
		stb.append(OmdConstants.MODIFIER + ":" + vr.modifier + ",");
		stb.append(OmdConstants.MODIFYTIME + ":" + vr.modifyTime);
		stb.append("}");
		return stb.toString();
	}
	
	/**
	 * 将VersionRule转化成xmltext
	 * @param bt
	 * @return
	 */
	public String getXmlText(VersionRule vr){
		StringBuilder stb = new StringBuilder("<versionRule>");
		stb.append("<name>" + vr.name + "</name>");
		stb.append("<tag>" + vr.tag + "</tag>");
		stb.append("<jumpCharacter>" + vr.jumpCharacter + "</jumpCharacter>");
		stb.append("<initialValue>" + vr.initialValue + "</initialValue>");
		stb.append("<stepLength>" + vr.stepLength + "</stepLength>");
		stb.append("<prefixion>" + vr.prefixion + "</prefixion>");
		stb.append("<suffix>" + vr.suffix + "</suffix>");
		stb.append("<description>" + vr.description + "</description>");
		stb.append("<associated>" + vr.associated + "</associated>");
		stb.append("</versionRule>");
		return stb.toString();
	}

	public List<VersionRule> getVRsFromFile(String dir) {
		File file = new File(dir + "/vr.txt");
		List<VersionRule> list = new ArrayList<VersionRule>();
		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 + "/vr/" + oid + ".xml");
					if(!contentFile.exists()){
						System.out.println(dir + "/vr/" + oid + ".xml不存在");
						break;
					}
					VersionRule em = new VersionRule();
					em.oid = oid;
					em.name = map.get("name");
					em.tag = map.get("label");
					em.ts = map.get("ts");
					em.creator = map.get("creator");
					em.createTime = Long.valueOf(map.get("createTime"));
					em.modifier = map.get("modifier");
					em.modifyTime = Long.valueOf(map.get("modifyTime"));
					em.description = map.get("description");	//add aby caill 2015.12.23 原代码中没有description一项，导致导入时，“描述”一栏没有值
					SAXReader sa = new SAXReader();
					//add by caill 2015.12.23	导入时将saxReader对象设置为“utf-8”格式
					sa.setEncoding("utf-8");
					Document document = sa.read(contentFile);
					setVRValueFormDoc(em, document.getRootElement());
					list.add(em);
				}else{
					System.out.println(dir + "vr.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.23	将fo关闭
					isw.close();	//add by caill 2015.12.23	将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 vr
	 * @param element
	 */
	public void setVRValueFormDoc(VersionRule vr, Element element){
		String value = element.elementText("jumpCharacter");
		vr.jumpCharacter = (value == null ? "" : value);
		value = element.elementText("initialValue");
		vr.initialValue = (value == null ? "" : value);
		value = element.elementText("stepLength");
		vr.stepLength = (value == null ? "" : value);
		value = element.elementText("prefixion");
		vr.prefixion = (value == null ? "" : value);
		value = element.elementText("suffix");
		vr.suffix = (value == null ? "" : value);
		value = element.elementText("associated");
		vr.associated = (value == null ? "" : value);
	}
	
	public boolean impData(VersionRule[] vrs) {
		try {
			for(VersionRule vr : vrs){
				VersionRule vr_ = getService().getVersionRule(vr.name);
				//已经存在
				if(!vr_.oid.equals("")){
					getService().deleteVersionRule(vr_);
					getService().addVersionRule(vr);
					System.out.println(vr.name + "在数据库中已经存在， 覆盖。");
				}else{
					getService().addVersionRule(vr);
				}
			}
			return true;
		} catch (VCIError e) {
			e.printStackTrace();
		}
		return false;
	}
}