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.Arrays;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;

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

import com.vci.corba.omd.atm.AttribItem;
import com.vci.corba.omd.btm.BTMServicePrx;
import com.vci.corba.omd.btm.BtmItem;
import com.vci.corba.omd.lcm.LifeCycle;
import com.vci.corba.omd.vrm.VersionRule;
import com.vci.client.common.ClientLog4j;
import com.vci.client.common.providers.ServiceProvider;
import com.vci.corba.common.VCIError;
import com.vci.omd.constants.OmdConstants;


/**
 * 对外部提供业务类型的属性列表
 * 获取属性的数据类型, 属性: 系统属性, 属性池属性
 * 
 */
public class BtmProvider {
	private static BTMServicePrx btmService = null;

	
	private BtmProvider(){
	}
	
	private static class InstanceHolder{
		public static BtmProvider btmProvider = new BtmProvider();
	}
	public static BtmProvider getInstance(){
		return InstanceHolder.btmProvider;
	}
	
	public static BTMServicePrx getService(){
		try {
			if (btmService == null) {
				btmService = ServiceProvider.getOMDService().getBTMService();
			}

			if (btmService == null)
			{
				ClientLog4j.logger.error("BtmProvider.getService, 获取【btmService】失败");
			}

			return btmService;
		} catch (Exception e) {
			e.printStackTrace();
		}
		
		return btmService;
	}
	
	public String[] getSysAttributes() {
		try {
			return getService().getSysAttributes();
		} catch (Exception e) {
			e.printStackTrace();
		}
		
		return null;
	}
	
	public AttribItem[] getSysAttribItems() {
		try {
			return getService().getSysAttribItems();
		} catch (Exception e) {
			e.printStackTrace();
		}
		
		return null;
	}
	
	
	/**
	 * 获取业务类型的属性列表
	 * @param btmName
	 * @return
	 */
	public AttribItem[] getBtAbItems(String btmName){
		AttribItem[] abItems;
		String[] abNames = null;
		
		try {
			abNames = getService().getBtmApNameArray(btmName);
		} catch (VCIError e) {
			e.printStackTrace();
		}
		
		abItems = ApProvider.getAttribItemsByNames(abNames);
		
		return abItems;
	}
	
	/**
	 * 获取全部业务类型
	 * @return
	 */
	public BtmItem[] getAllBtmItems(){
		BtmItem[] btmItems = null;
		try {
			btmItems = getService().getAllBtmItem("");
		} catch (VCIError e) {
			e.printStackTrace();
		}
		return btmItems;
	}
	
	/**
	 * 获取业务类型的子类型
	 * @param btmName
	 * @return
	 */
	public BtmItem[] getChildrenBtmItems(String btmName){
		BtmItem[] btmItems = null;
		try {
			btmItems = getService().getChildrenBtms(btmName);
		} catch (VCIError e) {
			e.printStackTrace();
		}
		return btmItems;
	}
	
	/**
	 * 获取指定的业务类型
	 * @param btmName
	 * @return
	 */
	public static BtmItem getBtmItemByName(String btmName){
		BtmItem btmItem = null;
		try {
			btmItem = getService().getBtmItemByName(btmName);
		} catch (VCIError e) {
			e.printStackTrace();
		}
		return btmItem;
	}
	/**
	 * 
	 * 获取业务类型的全部属性(包括系统属性)数组
	 * @return
	 */
	public static List<String> getAllAbNames(String btmName){
		List<String> abList = new ArrayList<String>();

		for (String attr : getService().getSysAttributes())
			abList.add(attr);
		
		String[] abNames = null;
		try {
			abNames = getService().getBtmApNameArray(btmName);
		} catch (VCIError e) {
			e.printStackTrace();
		}
		
		for(int i = 0; i < abNames.length; i++){
			abList.add(abNames[i]);
		}
		
		return abList;
	}
	
	/**
	 * 获取业务类型的属性(不包括系统属性)数组
	 * @param btmName
	 * @return
	 */
	public static String[] getAbNames(String btmName){
		String[] abNames = null;
		
		try {
			abNames = getService().getBtmApNameArray(btmName);
		} catch (VCIError e) {
			e.printStackTrace();
			abNames = new String[0];
		}
		
		return abNames;
	}
	
	/**
	 * 获取属性的数据类型, 属性: 系统属性, 属性池属性
	 * @param abUpperName
	 * @return"ISLastR","ISFirstR","ISLastV","ISFirstV",
	 */
	public static String getAbItemDataType(String abName){
		String dataType = null;
		String abUpperName = abName.toUpperCase();
		//系统属性
		if(abUpperName.equals("OID") || abUpperName.equals("REVISIONOID") || abUpperName.equals("NAMEOID") || abUpperName.equals("BTMNAME")
				|| abUpperName.equals("CREATOR") || abUpperName.equals("LASTMODIFIER") || abUpperName.equals("REVISIONRULE")
				|| abUpperName.equals("VERSIONRULE") || abUpperName.equals("REVISIONVALUE") || abUpperName.equals("VERSIONVALUE")
				|| abUpperName.equals("LCTID") || abUpperName.equals("LCSTATUS")
				|| abUpperName.equals("ID") || abUpperName.equals("NAME") || abUpperName.equals("DESCRIPTION") 
				|| abUpperName.equals("OWNER") || abUpperName.equals("CHECKINBY") 
				|| abUpperName.equals("CHECKOUTBY") || abUpperName.equals("COPYFROMVERSION")
				|| abUpperName.equals("ISLASTR") || abUpperName.equals("ISFIRSTR")
				|| abUpperName.equals("ISLASTV") || abUpperName.equals("ISFIRSTV")
				|| abUpperName.equals("F_OID") || abUpperName.equals("F_REVISIONOID") 
				|| abUpperName.equals("F_NAMEOID") || abUpperName.equals("F_BTWNAME")
				|| abUpperName.equals("T_OID") || abUpperName.equals("T_REVISIONOID") 
				|| abUpperName.equals("T_NAMEOID") || abUpperName.equals("T_BTWNAME")){
			dataType = "VTString";
		}else if(abUpperName.equals("REVISIONSEQ") || abUpperName.equals("VERSIONSEQ")){
			dataType = "VTInteger";
		}else if(abUpperName.equals("CREATETIME") || abUpperName.equals("LASTMODIFYTIME")
				|| abUpperName.equals("TS") || abUpperName.equals("CHECKINTIME") || abUpperName.equals("CHECKOUTTIME")){
			dataType = "VTDateTime";
		//属性池中属性
		}else{
			dataType = ApProvider.getAbItemDataType(abName);
		}
		return dataType;
	}
	
	/**
	 * (对外)提供业务类型的数据文件数据
	 * @return
	 */
	public static String getBTMData(){
		String content = "";
		try {
			content = getService().getBTMData();
		} catch (VCIError e) {
			e.printStackTrace();
		}
		return content;
	}
	
	
	/**
	 * 获取业务类型的公共基类列表
	 * @param btms
	 * @return
	 */
	public List<String> getCommonFBtmNames(List<String> btmNames){
		List<String> list = new ArrayList<String>();
		Map<String, List<String>> bListMap = new HashMap<String, List<String>>();
		for(int i = 0; i < btmNames.size(); i++){
			String btmName = btmNames.get(i);
			List<String> bNameList = getFBtmNameList(btmName);
			if(bNameList != null && bNameList.size() > 0){
				bListMap.put(btmName, bNameList);
			}
		}
		Iterator<String> ite = bListMap.keySet().iterator();
		//取第一个业务类型的父类型列表
		String firstName = null;
		List<String> bNameList = null;
		while(ite.hasNext()){
			firstName = ite.next();
			bNameList = bListMap.get(firstName);
			break;
		}
		if(bNameList == null || bNameList.size() < 1){
			return null;
		}
		//取第一个业务类型的父类型列表中的父类型
		for(int i = 0; i < bNameList.size(); i++){
			String fName = bNameList.get(i);
			//判断其他的业务类型父类型列表中是否全部含有 该父类型
			//当其他的的业务类型父类型列表中全部含有该父类型时, 该父类型即为 公共父类型
			Iterator<String> ite_ = bListMap.keySet().iterator();
			boolean flag = true;
			while(ite_.hasNext()){
				String btmName = ite_.next();
				if(btmName.equals(firstName)){
					continue;
				}
				bNameList = bListMap.get(btmName);
				if(!bNameList.contains(fName)){
					flag = false;
					break;
				}
			}
			if(flag){
				list.add(fName);
			}
		}
		return list;
	}
	
	/**
	 * 返回所有父类型名
	 * @param btmName
	 * @return
	 */
	public List<String> getFBtmNameList(String btmName){
		try {
			BtmItem btm = getService().getBtmItemByName(btmName);
			List<String> list = new ArrayList<String>();
			while(btm.fName != null && !btm.fName.equals("")){
				list.add(btm.fName);
				btm = getService().getBtmItemByName(btm.fName);
			}
			return list;
		} catch (VCIError e) {
			e.printStackTrace();
		}
		return null;
	}
	
	/**
	 * 获取业务类型的子类型名
	 */
	public String[] getChildrenNames(String btmName){
		try {
			return getService().getChildrenNames(btmName);
		} catch (VCIError e) {
			e.printStackTrace();
		}
		return null;
	}


	/**
	 * 获取属性other中type的值
	 * @param other
	 * @param type
	 * @return
	 */
	public static String getOtherValueByType(String other, String type){
		String[] otherArray = other.split(";");
		for(int i = 0; i < otherArray.length; i++){
			String otherValue = otherArray[i];
			if(otherValue.contains(type)){
				return otherValue.substring(otherValue.indexOf("=") + 2, otherValue.length());
			}
		}
		return null;
		
	}
	
	/**
	 * 获取属性字段的sql语句
	 * @param array
	 * @return
	 */
	public static String getAbSql(AttribItem abItem){
		String sql = "";
		if(abItem == null){
			return sql;
		}
		String abName = abItem.name;
		String vtType = abItem.vtDataType;
		String other = abItem.other;
		String defValue = abItem.defValue;
		
		if(vtType.equals("VTString")){
			int length = 50;
			String lengthStr = getOtherValueByType(other, "length");
			if(lengthStr != null && !lengthStr.equals("")){
				length = Integer.valueOf(lengthStr);
			}
			sql += abName.toUpperCase() + " VARCHAR2(" + length + ")";
			if(!defValue.equals("")){
				sql += " default '" + defValue + "'";
			}
			sql += ",\n\t";
		}else if(vtType.equals("VTInteger") || vtType.equals("VTLong")){
			sql += abName.toUpperCase() + " NUMBER";
			if(!defValue.equals("")){
				sql += " default " + defValue;
			}
			sql += ",\n\t";
		}else if(vtType.equals("VTDouble")){
			int length = 20;
			String lengthStr = getOtherValueByType(other, "length");
			if(lengthStr != null && !lengthStr.equals("")){
				length = Integer.valueOf(lengthStr);
			}
			
			int accuracy = 2;
			String accuracyStr = getOtherValueByType(other, "accuracy");
			if(accuracyStr != null && !accuracyStr.equals("")){
				accuracy = Integer.valueOf(accuracyStr);
			}
			sql += abName.toUpperCase() + " NUMBER(" + length + ", " + accuracy +")";
			if(!defValue.equals("")){
				sql += " default " + defValue;
			}
			sql += ",\n\t";
		}else if(vtType.equals("VTBoolean")){
			sql += abName.toUpperCase() + " VARCHAR2(8)";
			if(!defValue.equals("")){
				sql += " default '" + defValue + "'";
			}
			sql += ",\n\t";
		}else if(vtType.equals("VTImage")){
			sql += abName.toUpperCase() + " VARCHAR2(255)";
			sql += ",\n\t";
		}else if(vtType.equals("VTDate")){
			sql += abName.toUpperCase() + " DATE";
			sql += ",\n\t";
		}else if(vtType.equals("VTTime")){
			sql += abName.toUpperCase() + " TIMESTAMP";
			sql += ",\n\t";
		}else if(vtType.equals("VTDateTime")){
			sql += abName.toUpperCase() + " TIMESTAMP";
			sql += ",\n\t";
		}else if(vtType.equals("VTNote")){
			sql += abName.toUpperCase() + " VARCHAR2(255)";
			sql += ",\n\t";
		}else if(vtType.equals("VTFilePath")){
			sql += abName.toUpperCase() + " VARCHAR2(255)";
			sql += ",\n\t";
		}else if(vtType.equals("VTClob")){
			sql += abName.toUpperCase() + " CLOB";
			sql += ",\n\t";
		}
		
		return sql;
	}
	
	/**
	 * 生成创建业务类型的DDL
	 * @param btm
	 * @return
	 */
//	public static String getCreateBTMTableSql(BtmItem btm){
//		String btmName = btm.name;
//		String btmTableName = OmdTools.getBTTableName(btmName);
//		String sql = "create Table " + btmTableName + "(" + OmdTools.getOtherFieldBtSql();
//		String[] apNames = null;
//		try {
//			apNames = getService().getBtmApNameArray(btmName);
//		} catch (VCIError e) {
//			e.printStackTrace();
//		}
//		if(apNames != null && apNames.length != 0){
//			for(int k = 0; k < apNames.length; k++){
//				String abName = apNames[k];
//				AttribItem abItem = null;
//
//				abItem = ApProvider.getAbItemByName(abName);
//
//				String abSql = getAbSql(abItem);
//				sql += abSql;
//			}
//		}
//		
//		sql = sql.substring(0, sql.lastIndexOf(","));
//		sql += "\n)";
//		return sql;
//	}
	/**
	 * 将业务类型树导出为.sql文件
	 * add by caill 2015.12.21
	 * */
//	public boolean expBtmDataSql(String dir, BtmItem[] allBtmItems) throws VCIError {
//		new File(dir).mkdir();
//		File file = new File(dir + "/platformBtm.sql");
//		FileWriter w = null;;
//		BufferedWriter bw = null;
//		try {
//			w = new FileWriter(file);
//		    bw = new BufferedWriter(w);
//		} catch (IOException e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		}
//		
//		for(int i = 0; i < allBtmItems.length; i++){
//			String sql = getBTMTableSqlByName(allBtmItems[i]);
//			try {
//				bw.write(sql);
//				bw.write("\r\n");
//			} catch (IOException e) {
//				// TODO Auto-generated catch block
//				e.printStackTrace();
//			}	
//		}
//		try {
//			bw.flush();
//			bw.close();
//			return true;
//		} catch (IOException e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		}
//		
//		
//		return false;
//	}

	/**
	 * 生成业务类型导出为.sql文件的sql语句 add by caill 2015.12.21
	 * @param btm
	 * @return
	 */
//	public String getBTMTableSqlByName(BtmItem allBtmItem){
//		String btmTableName = OmdTools.getBTTableName(allBtmItem.name);
//		String sql = "create Table " + btmTableName + "(" + OmdTools.getOtherFieldBtSql();
//		String[] apNames = null;
//		try {
//			apNames = getService().getBtmApNameArray(allBtmItem.name);
//		} catch (VCIError e) {
//			e.printStackTrace();
//		}
//		if(apNames != null && apNames.length != 0){
//			for(int k = 0; k < apNames.length; k++){
//				String abName = apNames[k];
//				AttribItem abItem = null;
//
//				abItem = ApProvider.getAbItemByName(abName);
//
//				String abSql = getAbSql(abItem);
//				sql += abSql;
//			}
//		}
//		
//		sql = sql.substring(0, sql.lastIndexOf(","));
//		sql += "\n);";
//		sql += "\r\ncomment on table "+btmTableName+" is '"+allBtmItem.label +"';";	//添加表注释
//		if(apNames != null && apNames.length != 0){
//			for(int k = 0; k < apNames.length; k++){
//				String abName = apNames[k];
//				AttribItem abItem = null;
//
//				abItem = ApProvider.getAbItemByName(abName);
//
//				sql += "\r\ncomment on column "+btmTableName+"."+abItem.name+" is '"+ abItem.label +"';";
//			}
//		}
//		return sql;
//	}
	
	/**
	 * 获取增加主键sql
	 * @param typeName
	 * @return
	 */
//	public static String getAddPKSql(String typeName){
//		return "alter table " + OmdTools.getBTTableName(typeName) + " add constraint PKBTM_" + typeName + " primary key (OID)\n";
//	}
	
	/**
	 * Array-->List
	 * @param array
	 * @return
	 */
	public List<String> parseArrayToList(String[] array){
		List<String> list = new ArrayList<String>();
		for(int i = 0; i < array.length; i++){
			list.add(array[i]);
		}
		return list;
	}
	
	/**
	 * Array-->List
	 * @param array
	 * @return
	 */
	public List<Integer> parseArrayToList(int[] array){
		List<Integer> list = new ArrayList<Integer>();
		for(int i = 0; i < array.length; i++){
			list.add(array[i]);
		}
		return list;
	}
	
	/**
	 * Array-->String
	 * @param array
	 * @return
	 */
	public static String arrayTOString(String[] array){
		String str = "";
		if(array != null && array.length > 0){
			for(int i = 0; i < array.length; i++){
				str += array[i];
				str += ",";
			}
			str = str.substring(0, str.lastIndexOf(","));
		}
		return str;
	}
	
	public static boolean expData(String dir, BtmItem[] bts){
		Set<String> attNameSet = new HashSet<String>();
		Set<String> lcNameSet = new HashSet<String>();
		Set<String> vrNameSet = new HashSet<String>();
		BufferedWriter bw = null;
		FileOutputStream fos = null;
		OutputStreamWriter osw =null;
		try{
			new File(dir).mkdir();		//首先新建目录 modify by zhonggy
			File file = new File(dir + "/bt.txt");
			//将clob字段写到单独的文件中
			/*new File(dir + "/bt").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(BtmItem bt : bts){
				String[] apNames = bt.apNameArray;
				if(apNames.length > 0){
					attNameSet.addAll(Arrays.asList(apNames));
				}
				if(!bt.lifeCycle.equals("")){
					lcNameSet.add(bt.lifeCycle);
				}
				for(String lcName : bt.lifeCycles){
					lcNameSet.add(lcName);
				}
				
				if(!bt.revRuleName.equals("")){
					vrNameSet.add(bt.revRuleName);
				}
				//若str小于缓冲区大小, 将写到缓冲区; 
				//若str大于缓冲区大小, 将刷新缓冲区(将缓冲区内容写到底层流), 然后str直接写到底层流.
				String text = getObjectText(bt);
				bw.write(text);
				bw.newLine();
				BufferedWriter clobBW = null;
				FileOutputStream fo = null;
				OutputStreamWriter pw =null;
				try{
					new File(dir + "/bt").mkdir();
					File clobFile = new File(dir + "/bt/" + bt.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(bt));
					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(bt));
					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();
			//导出属性
			AttribItem[] abs = ApProvider.getAttribItemsByNames(attNameSet.toArray(new String[0]));			
			boolean apFlag = ApProvider.expData(dir, abs);
			
			List<LifeCycle> lcs = new ArrayList<LifeCycle>();
			for(String lcName : lcNameSet){
				LifeCycle lifeCycle = LifeCycleProvider.getInstance().getService().getLifeCycle(lcName);
				lcs.add(lifeCycle);
			}
			boolean lcFlag = LifeCycleProvider.getInstance().expData(dir, lcs.toArray(new LifeCycle[0]));
			List<VersionRule> vrs = new ArrayList<VersionRule>();
			for(String vrName : vrNameSet){
				VersionRule vr = VersionRuleProvider.getInstance().getService().getVersionRule(vrName);
				vrs.add(vr);
			}
			boolean vrFlag = VersionRuleProvider.getInstance().expData(dir, vrs.toArray(new VersionRule[0]));
			
			if(true & apFlag & lcFlag & vrFlag){
				System.out.println("**************业务类型导出成功************");
			}else{
				System.out.println("**************业务类型导出失败************");
			}
			
			return true & apFlag;
		}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 bt
	 * @return
	 */
	public static String getObjectText(BtmItem bt) {
		StringBuilder stb = new StringBuilder("{");
		stb.append(OmdConstants.OID + ":" + bt.oid + ",");
		stb.append(OmdConstants.NAME + ":" + bt.name + ",");
		stb.append(OmdConstants.LABEL + ":" + bt.label + ",");
		stb.append(OmdConstants.DESCRIPTION + ":" + bt.description + ",");
		stb.append(OmdConstants.TS + ":" + bt.ts + ",");
		stb.append(OmdConstants.CREATOR + ":" + bt.creator + ",");
		stb.append(OmdConstants.CREATETIME + ":" + bt.createTime + ",");
		stb.append(OmdConstants.MODIFIER + ":" + bt.modifier + ",");
		stb.append(OmdConstants.MODIFYTIME + ":" + bt.modifyTime);
		stb.append("}");
		return stb.toString();
	}
	
	/**
	 * 将bt转化成xmltext
	 * @param o
	 * @return
	 */
	public static String getXmlText(BtmItem o){
		String apNameArray = arrayTOString(o.apNameArray);
		String lifeCycles = arrayTOString(o.lifeCycles);
		StringBuilder stb = new StringBuilder("<btm>");
		stb.append("<name>" + o.name + "</name>");
		stb.append("<label>" + o.label + "</label>");
		stb.append("<description>" + o.description + "</description>");
		stb.append("<isAbstract>" + o.isAbstract + "</isAbstract>");
		stb.append("<shape>" + o.shape + "</shape>");
		stb.append("<implClass>" + o.implClass + "</implClass>");
		stb.append("<fName>" + o.fName + "</fName>");
		stb.append("<lifeCycle>" + o.lifeCycle + "</lifeCycle>");
		stb.append("<imageName>" + o.imageName + "</imageName>");
		stb.append("<revLevel>" + o.revLevel + "</revLevel>");
		stb.append("<revRuleName>" + o.revRuleName + "</revRuleName>");
		stb.append("<revInput>" + o.revInput + "</revInput>");
		stb.append("<delimiter>" + o.delimiter + "</delimiter>");
		stb.append("<verRuleName>" + o.verRuleName + "</verRuleName>");
		stb.append("<apNameArray>" + apNameArray + "</apNameArray>");
		stb.append("<lifeCycles>" + lifeCycles + "</lifeCycles>");
		stb.append("</btm>");
		return stb.toString();
	}
	
	public static List<BtmItem> getBTFromFile(String dir) {
		File file = new File(dir + "/bt.txt");
		List<BtmItem> list = new ArrayList<BtmItem>();
		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 + "/bt/" + oid + ".xml");
					if(!contentFile.exists()){
						System.out.println(dir + "/bt/" + oid + ".xml不存在");
						break;
					}
					BtmItem bt = new BtmItem();
					bt.oid = oid;
					bt.name = map.get("name");
					bt.label = map.get("label");
					bt.description = map.get("description");
					bt.ts = Long.valueOf(map.get("ts"));
					bt.creator = map.get("creator");
					bt.createTime = Long.valueOf(map.get("createTime"));
					bt.modifier = map.get("modifier");
					bt.modifyTime = Long.valueOf(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);
					setBTValueFormDoc(bt, document.getRootElement());
					list.add(bt);
				}else{
					System.out.println(dir + "bt.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 static 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 att
	 * @param element
	 */
	public static void setBTValueFormDoc(BtmItem bt, Element element){
		String value = element.elementText("isAbstract");
		bt.isAbstract = (value == null ? false : Boolean.valueOf(value));
		value = element.elementText("fName");
		bt.fName = (value == null ? "" : value);
		value = element.elementText("implClass");
		bt.implClass = (value == null ? "" : value);
		value = element.elementText("shape");
		bt.shape = (value == null ? "" : value);
		value = element.elementText("lifeCycle");
		bt.lifeCycle = (value == null ? "" : value);
		value = element.elementText("lifeCycles");
		if(value != null && !value.equals("")){
			bt.lifeCycles = value.trim().split(",");
		}else{
			bt.lifeCycles = new String[0];
		}
		value = element.elementText("imageName");
		bt.imageName = (value == null ? "" : value);
		value = element.elementText("revLevel");
		bt.revLevel = (value == null ? 0 : Short.valueOf(value));
		value = element.elementText("revRuleName");
		bt.revRuleName = (value == null ? "" : value);
		value = element.elementText("revInput");
		bt.revInput = (value == null ? false : Boolean.valueOf(value));
		value = element.elementText("delimiter");
		bt.delimiter = (value == null ? "" : value);
		value = element.elementText("verRuleName");
		bt.verRuleName = (value == null ? 0 : Short.valueOf(value));
		value = element.elementText("apNameArray");
		if(value != null && !value.equals("")){
			bt.apNameArray = value.trim().split(",");
		}else{
			bt.apNameArray = new String[0];
		}
	}
	
	public static boolean impData(String dir, BtmItem[] bts) {
		try {
			List<AttribItem> atts = ApProvider.getAttFromFile(dir);
			boolean attFlag = ApProvider.impData(dir, atts.toArray(new AttribItem[0]));
			if(!attFlag){
				System.out.println("业务类型使用的属性导入失败。导入中止。");
				return false;
			}
			
			List<VersionRule> vrs = VersionRuleProvider.getInstance().getVRsFromFile(dir);
			boolean vrFlag = VersionRuleProvider.getInstance().impData(vrs.toArray(new VersionRule[0]));
			if(!vrFlag){
				System.out.println("业务类型使用的版本规则导入失败。导入中止。");
				return false;
			}
			
			List<LifeCycle> lcs = LifeCycleProvider.getInstance().getLCFromFile(dir);
			boolean lcFlag = LifeCycleProvider.getInstance().impData(dir, lcs.toArray(new LifeCycle[0]));
			if(!lcFlag){
				System.out.println("业务类型使用的生命周期导入失败。导入中止。");
				return false;
			}
			
			for(BtmItem bt : bts){
				BtmItem bt_ = getService().getBtmItemByName(bt.name);
				//已经存在
				if(!bt_.oid.equals("")){
					getService().deleteBtmItem(bt_);
					getService().addBtmItem(bt);
					System.out.println(bt.name + "在数据库中已经存在， 覆盖。");
				}else{
					getService().addBtmItem(bt);
				}
			}
			return true;
		} catch (VCIError e) {
			e.printStackTrace();
		}
		return false;
	}
	
	/**
	 * 设置索引
	 * @param typeName
	 * @param indexAttr
	 * @return
	 */
//	public String getAddIndex(String typeName,String[] indexAttr){
//		String sql = "create unique INDEX "+indexAttr[0]+" on " + OmdTools.getBTTableName(typeName) + "(" + indexAttr[1] + ")\n";
//		return sql;
//	}
	/**
	 * 修改索引
	 * @param typeName
	 * @param indexAttr
	 * @return
	 */
//	public String getDropIndex(String typeName,String[] indexAttr){
//		String sql = "drop INDEX "+indexAttr[0]+" \n";
//		return sql;
//	}
	
	public boolean addIndex(String typeName, String[] indexAttr){
		try {
			return getService().addIndex(typeName, indexAttr);
		} catch (VCIError e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		return false;
	}
	
	public boolean dropIndex(String typeName, String[] indexAttr){
		try {
			return getService().dropIndex(typeName, indexAttr);
		} catch (VCIError e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		return false;
	}
	
}