package com.vci.server.bof.service;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.Reader;
import java.sql.Clob;
import java.sql.Date;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Timestamp;
import java.sql.Types;
import java.util.HashMap;
import java.util.Map;

import org.hibernate.SQLQuery;

import com.vci.corba.common.VCIError;
import com.vci.corba.omd.atm.AttribItem;
import com.vci.corba.omd.lcm.LifeCycle;
import com.vci.omd.constants.BusinessConstants;
import com.vci.server.cache.OMCacheProvider;
import com.vci.common.log.ServerWithLog4j;

public class BOFactoryBaseService {

	public static String DATEFORMATTER = "yyyy-mm-dd hh24:mi:ss.ff";
	public static String DATEFORMATTER_YMD = "yyyy-mm-dd";
	
	/**
	 * 获取业务类型的所有属性
	 * @param boName
	 * @return
	 * @throws Exception
	 * @throws Throwable
	 */
	public AttribItem[] getBOAttributeItem(String boName) throws Exception, Throwable {
		ServerWithLog4j.logger.debug("getBOAttributeItem boName = " + boName);	
		
		//OMDServicePrx omd = ServerServiceProvider.getOMDService();
		//AttribItem[] items = BtmProvider.getInstance().getBtAbItems(boName);
		//String[] attrs = omd.getBTMService().getBtmApNameArray(boName); //LinkTypeProvider.getInstance().getLTAbItems(loName);
		//AttribItem[] items = omd.getAttributeService().getAttribItemsByNames(attrs);
		
		String[] attrs = OMCacheProvider.getBTAttributes(boName);
		
		AttribItem[] items = new AttribItem[attrs.length];
		for (int i = 0; i < attrs.length; i++) {
			items[i] = OMCacheProvider.getAttribute(attrs[i]);
		}

		return items;
	}
	
	public Map<String, AttribItem> getBOAttributeItemMap(String boName) throws Exception, Throwable {
		ServerWithLog4j.logger.debug("getBOAttributeItemMap boName = " + boName);		
		
		AttribItem[] items = getBOAttributeItem(boName);//BtmProvider.getInstance().getBtAbItems(boName);
		Map<String, AttribItem> itemMap = new HashMap<String, AttribItem>();
		for (int i = 0; i < items.length; i++) {
			itemMap.put(items[i].name.toLowerCase(), items[i]);
		}
		return itemMap;
	}
	
    public AttribItem[] getLOAttributeItem(String loName) throws Exception, Throwable {
		//OMDServicePrx omd = ServerServiceProvider.getOMDService();

    	//LinkType lt = omd.getLinkTypeService().getLinkType(loName);
		//String[] attrs = ltService.getLTNamesByAPName(loName); //LinkTypeProvider.getInstance().getLTAbItems(loName);
		//AttribItem[] items = omd.getAttributeService().getAttribItemsByNames(lt.attributes);
		AttribItem[] items = null;
		String[] attrs = OMCacheProvider.getLTAttributes(loName);
		if (attrs != null) {
			int count = attrs.length;
			items = new AttribItem[count];
			for (int i = 0; i < count; i++) {
				items[i] = OMCacheProvider.getAttribute(attrs[i]);
			}
		}
		return items;
	}
	
    public Map<String, AttribItem> getLOAttributeItemMap(String loName) throws Exception, Throwable {
    	AttribItem[] items = getLOAttributeItem(loName);//LinkTypeProvider.getInstance().getLTAbItems(loName);
		Map<String, AttribItem> itemMap = new HashMap<String, AttribItem>();
		for (int i = 0; i < items.length; i++) {
			itemMap.put(items[i].name.toLowerCase(), items[i]);
		}
		return itemMap;
	}
	
	public Map<String, String> getBOAttributeItemDefaultValMap(String boName) throws Exception, Throwable {
		Map<String, String> itemMap = new HashMap<String, String>();
		AttribItem[] items = getBOAttributeItem(boName);
		if (items != null) {
			for (int i = 0; i < items.length; i++) {
				itemMap.put(items[i].name.toLowerCase(), items[i].defValue);
			}
		}
		return itemMap;
	}
	
	public Map<String, String> getBOAttributeItemDefaultValMap(String boName, Map<String, AttribItem> attrNameMap) throws Exception, Throwable {
		Map<String, String> itemMap = new HashMap<String, String>();
		AttribItem[] items = getBOAttributeItem(boName);
		if (items != null) {
			for (int i = 0; i < items.length; i++) {
				itemMap.put(items[i].name, items[i].defValue);
				attrNameMap.put(items[i].name.toLowerCase(), items[i]);
			}
		}
		return itemMap;
	}
	
	public Map<String, String> getLOAttributeItemDefaultValMap(String loName) throws Exception, Throwable {
		Map<String, String> itemMap = new HashMap<String, String>();
		AttribItem[] items = getLOAttributeItem(loName);
		if (items != null) {
			for (int i = 0; i < items.length; i++) {
				itemMap.put(items[i].name.toLowerCase(), items[i].defValue);
			}
		}
		return itemMap;
	}
	
	
	protected boolean isBOAttribute(String attrName, Map<String, String> attrMap) {
		if (attrMap.containsKey(attrName.toLowerCase()) 
				|| attrMap.containsKey(attrName.toUpperCase()) 
				|| BusinessConstants.isBusinessConstants(attrName.toUpperCase())) {
			return true;
		} else {
			return false;
		}
	}
	
	/**
	 * 根据类型名称获取对应的表名称
	 * 
	 * @param btmName
	 * @return
	 */
//	public String getTableName(String btmName) {
//		return OmdTools.getBTTableName(btmName);
//	}
	
	/**
	 * 获取去初始版本
	 * @param verRuleName
	 * @return
	 */
	public String getVersionValue(int verRuleName) {
		String value = "0";
		if (verRuleName == 0) {
			value = "1";
		} else if (verRuleName == 1){
			value = "a";
		} else if (verRuleName == 2) {
			value = "0";
		}
		return value;
	}
	
	/**
	 * 根据生命周期名称获取第一个生命周期节点
	 * @param lifeCycleName
	 * @return
	 * @throws VCIError 
	 */
	public String getLcFirstStatus(String lifeCycleName) throws VCIError {
		try {
			//LifeCyle[] lifeCycls = LifeCycleProvider.getInstance().getLifeCyles();
			//LifeCycle lifeCycle = ServerServiceProvider.getOMDService().getLifeCycleService().getLifeCycle(lifeCycleName);
			LifeCycle lifeCycle = OMCacheProvider.getLifeCycle(lifeCycleName);
			
			if (lifeCycle.name.equals(lifeCycleName)) {
				return lifeCycle.startState;
			}
		} catch (Exception e) {
			e.printStackTrace();
			throw new VCIError();
		} catch (Throwable e) {
			e.printStackTrace();
			throw new VCIError();
		}
		return "";
	}
	
	/**
	 * 根据类型构建插入的sql语句
	 * 
	 * @param attrItem
	 *            ，格式
	 * @param value
	 *            ，值
	 * @return
	 */
	public String getSqlAccordingType(AttribItem attrItem, String value) {
		StringBuilder sqlBuffer = new StringBuilder();
		if (value == null || value.trim().equals("")) {
			sqlBuffer.append("'").append(value).append("'");
			return sqlBuffer.toString();
		}
		if (attrItem.vtDataType.equals("VTInteger")
				|| attrItem.vtDataType.equals("VTLong")
				|| attrItem.vtDataType.equals("VTDouble")) {
			sqlBuffer.append(value);
		} else if (attrItem.vtDataType.equals("VTDate")) {
			sqlBuffer.append("to_date('").append(value).append("','")
			.append(DATEFORMATTER_YMD).append("')");
		} else if (attrItem.vtDataType.equals("VTTime")
				|| attrItem.vtDataType.equals("VTDateTime")) {
			sqlBuffer.append("to_timestamp('").append(value).append("','")
					.append(DATEFORMATTER).append("')");
		} else {
			sqlBuffer.append("'").append(value).append("'");
		}
		return sqlBuffer.toString();
	}
	
	public void setQueryValueAccordingDataType(SQLQuery query,
			AttribItem attrItem, int index, String value) {
		if (value == null || value.trim().equals("")) {
			query.setString(index, value);
			return;
		}
		if (attrItem.vtDataType.equals("VTString")) {
			query.setString(index, value);
		} else if (attrItem.vtDataType.equals("VTInteger")) {
			query.setInteger(index, Integer.valueOf(value).intValue());
		} else if (attrItem.vtDataType.equals("VTLong")) {
			query.setLong(index, Long.valueOf(value).longValue());
		} else if (attrItem.vtDataType.equals("VTDouble")) {
			query.setDouble(index, Double.valueOf(value).doubleValue());
		} else if (attrItem.vtDataType.equals("VTBoolean")) {
			query.setString(index, value);
		} else if (attrItem.vtDataType.equals("VTImage")) {
			query.setString(index, value);
		} else if (attrItem.vtDataType.equals("VTDate")) {
			if (value.isEmpty())
				query.setParameter(index, null);
			else{
				if(value.contains(":") && value.contains(" ")){
					value = value.substring(0,value.indexOf(" "));
				}
				query.setDate(index, Date.valueOf(value));
			}
			//query.setDate(index, Date.valueOf(value));
		} else if (attrItem.vtDataType.equals("VTTime")) {
			if (value.isEmpty())
				query.setParameter(index, null);
			else
				query.setTimestamp(index, Timestamp.valueOf(value));
		} else if (attrItem.vtDataType.equals("VTDateTime")) {
			if (value.isEmpty())
				query.setParameter(index, null);
			else
				query.setTimestamp(index, Timestamp.valueOf(value));
		} else if (attrItem.vtDataType.equals("VTNote")) {
			query.setString(index, value);
		} else if (attrItem.vtDataType.equals("VTFilePath")) {
			query.setString(index, value);
		}  else if (attrItem.vtDataType.equals("VTClob")) {
			query.setString(index, value);
		} else {
			query.setString(index, value);
		}
	}
	public void setQueryValueAccordingDataType(PreparedStatement pst,
			AttribItem attrItem, int index, String value) throws SQLException {
		// 本段有严重的缺陷
		// 对于VTInteger\VTLong\VTDobule类型时，
		// 如果value为空时，setString(index, value)  相当于为数值列设置了string类型的值，
		// 此时执行时会抛出异常
		// 方案：删除此段，改取属性池定义的默认值，
		// 如果 定义的默认值为空时，则给0
//		if (value == null || value.trim().equals("")) {
//			pst.setString(index, value);
//			return;
//		}
		if (value == null){
			pst.setNull(index, getSqlType(attrItem));
			return;
		}
		
		if (attrItem.vtDataType.equals("VTString")) {
			pst.setString(index, value);
		} else if (attrItem.vtDataType.equals("VTInteger")) {
			Integer val = isEmptyOrNull(value) ? (Integer)getDefVal(attrItem) : Integer.valueOf(value).intValue();
			pst.setInt(index, val);
		} else if (attrItem.vtDataType.equals("VTLong")) {
			Long val = isEmptyOrNull(value) ? (Long)getDefVal(attrItem) : Long.valueOf(value).longValue();
			pst.setLong(index, val);
		} else if (attrItem.vtDataType.equals("VTDouble")) {
			Double val = isEmptyOrNull(value) ? (Double)getDefVal(attrItem) : Double.valueOf(value).doubleValue();
			pst.setDouble(index, val);
		} else if (attrItem.vtDataType.equals("VTBoolean")) {
			pst.setString(index, value);
		} else if (attrItem.vtDataType.equals("VTImage")) {
			pst.setString(index, value);
		} else if (attrItem.vtDataType.equals("VTDate")) {
			if (value.isEmpty())
				pst.setNull(index, Types.DATE);
			else{
				if(value.contains(":") && value.contains(" ")){
					value = value.substring(0,value.indexOf(" "));
				}
				pst.setDate(index, Date.valueOf(value));
			}
		} else if (attrItem.vtDataType.equals("VTTime")) {
			if (value.isEmpty())
				pst.setNull(index, Types.TIMESTAMP);
			else
				pst.setTimestamp(index, Timestamp.valueOf(value));
		} else if (attrItem.vtDataType.equals("VTDateTime")) {
			if (value.isEmpty())
				pst.setNull(index, Types.TIMESTAMP);
			else
				pst.setTimestamp(index, Timestamp.valueOf(value));
		} else if (attrItem.vtDataType.equals("VTNote")) {
			pst.setString(index, value);
		} else if (attrItem.vtDataType.equals("VTFilePath")) {
			pst.setString(index, value);
		}  else if (attrItem.vtDataType.equals("VTClob")) {
			pst.setString(index, value);
		} else {
			pst.setString(index, value);
		}
	}
	
	protected int getSqlType(AttribItem attrItem){
		int sqlType = Types.VARCHAR;
		
		if (attrItem.vtDataType.equals("VTString")) {
			sqlType = Types.VARCHAR;
		} else if (attrItem.vtDataType.equals("VTInteger")) {
			sqlType = Types.NUMERIC;
		} else if (attrItem.vtDataType.equals("VTLong")) {
			sqlType = Types.NUMERIC;
		} else if (attrItem.vtDataType.equals("VTDouble")) {
			sqlType = Types.DOUBLE;
		} else if (attrItem.vtDataType.equals("VTBoolean")) {
			sqlType = Types.VARCHAR;
		} else if (attrItem.vtDataType.equals("VTImage")) {
			sqlType = Types.VARCHAR;
		} else if (attrItem.vtDataType.equals("VTDate")) {
			sqlType = Types.DATE;
		} else if (attrItem.vtDataType.equals("VTTime")) {
			sqlType = Types.TIMESTAMP;
		} else if (attrItem.vtDataType.equals("VTDateTime")) {
			sqlType = Types.TIMESTAMP;
		} else if (attrItem.vtDataType.equals("VTNote")) {
			sqlType = Types.VARCHAR;
		} else if (attrItem.vtDataType.equals("VTFilePath")) {
			sqlType = Types.VARCHAR;
		}  else if (attrItem.vtDataType.equals("VTClob")) {
			sqlType = Types.VARCHAR;
		} else {
			sqlType = Types.VARCHAR;
		}
		
		return sqlType;
	}

	protected boolean isEmptyOrNull(String value){
		return ((value == null) || "".equals(value.trim()));
	}
	private Object getDefVal(AttribItem attrItem){
		Object res = null;
		if (attrItem.vtDataType.equals("VTInteger")) {
			res = isEmptyOrNull(attrItem.defValue) ? Integer.valueOf(0).intValue() : Integer.valueOf(attrItem.defValue).intValue();
		} else if (attrItem.vtDataType.equals("VTLong")) {
			res = isEmptyOrNull(attrItem.defValue) ? Long.valueOf(0).longValue() : Long.valueOf(attrItem.defValue).longValue();
		} else if (attrItem.vtDataType.equals("VTDouble")) {
			res = isEmptyOrNull(attrItem.defValue) ? Double.valueOf(0).doubleValue() : Double.valueOf(attrItem.defValue).doubleValue();
		}
		return res;
	}
	/**
	 * clob转String
	 * @param value
	 * @return
	 */
	private String clobToString(Clob value) {
		// TODO Auto-generated method stub
		String clobValue = "";
		try {
			Reader is = value.getCharacterStream();
			BufferedReader br = new BufferedReader(is);
			String s = br.readLine();
			StringBuffer sb = new StringBuffer();
			while(s!=null){
				sb.append(s);
				s=br.readLine();
			}
			clobValue = sb.toString();
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		return clobValue;
	}
}