package com.vci.server.omd.qt.cache;

import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;

import org.apache.commons.lang3.StringUtils;
import org.hibernate.SQLQuery;
import org.hibernate.Session;

import com.alibaba.fastjson.JSONObject;
import com.vci.corba.omd.qtm.QTD;
import com.vci.corba.omd.qtm.QTInfo;
import com.vci.server.base.persistence.dao.HibernateSessionFactory;
import com.vci.server.cache.CacheNames;
import com.vci.server.cache.redis.RedisUtil;
import com.vci.server.omd.qt.dao.impl.QTDaoImpl;
import com.vci.server.omd.qt.entity.QTEntity;

public class QTDServerCacheUtil {

	private DateFormat dFormat = new SimpleDateFormat("yyyy-MM-dd");
	private static volatile QTDServerCacheUtil instance = null;
	
	
	public static void initCache() {
		clearCache();
		
		getInstance().initQTD();
		getInstance().initQt();
	}
	
	public static void clearCache() {
		RedisUtil.getInstance().del(CacheNames.QTCACHE);
		RedisUtil.getInstance().del(CacheNames.QTDCACHE);
	}
	
	public static void setQTemplate(QTInfo qt) {
		if (qt == null)
			return;
		
		String jsonObj = JSONObject.toJSONString(qt);
		
		RedisUtil.getInstance().hset(CacheNames.QTCACHE, qt.qtName.toLowerCase(), jsonObj);
	}
	
	public static void setQTD(QTD qtd) {
		if (qtd == null)
			return;
		
		String jsonObj = JSONObject.toJSONString(qtd);
		
		RedisUtil.getInstance().hset(CacheNames.QTDCACHE, qtd.name.toLowerCase(), jsonObj);
	}
	

	public static void delQTemplate(String name) {
		if (StringUtils.isBlank(name))
			return;
		
		RedisUtil.getInstance().hdel(CacheNames.QTCACHE, name.toLowerCase());
	}

	public static void delQTD(String name) {
		if (StringUtils.isBlank(name))
			return;
		
		RedisUtil.getInstance().hdel(CacheNames.QTDCACHE, name.toLowerCase());
	}
	
	
	public static QTD getQTD(String name) {
		String attrObj = RedisUtil.getInstance().hget(CacheNames.QTDCACHE, name.toLowerCase());
		if (StringUtils.isBlank(attrObj))
			return null;
		
		return JSONObject.parseObject(attrObj, QTD.class);
	}
	
	public static boolean isExistsQTD(String name) {
		String json = RedisUtil.getInstance().hget(CacheNames.QTDCACHE, name.toLowerCase());
		
		if (StringUtils.isBlank(json))
			return false;
		return true;
	}
	
	public static QTD[] getBizTypeQTDs(String name) {
		Map<String, String> map = RedisUtil.getInstance().hgetAll(CacheNames.QTDCACHE);
		List<QTD> lstItem = new ArrayList<QTD>();
		
		String[] items = map.values().toArray(new String[0]);
		for (int i = 0; i < items.length; i++) {
			QTD qtd = JSONObject.parseObject(items[i], QTD.class);
			if (qtd.btmName.equalsIgnoreCase(name))
				lstItem.add(qtd);
		}
		
		return lstItem.toArray(new QTD[0]);
	}
	
	public static QTD[] getLinkTypeQTDs(String name) {
		Map<String, String> map = RedisUtil.getInstance().hgetAll(CacheNames.QTDCACHE);
		List<QTD> lstItem = new ArrayList<QTD>();
		
		String[] items = map.values().toArray(new String[0]);
		for (int i = 0; i < items.length; i++) {
			QTD qtd = JSONObject.parseObject(items[i], QTD.class);
			if (qtd.linkTypeName.equalsIgnoreCase(name))
				lstItem.add(qtd);
		}
		
		return lstItem.toArray(new QTD[0]);
	}

	
	public static QTD[] getAllQTD() {
		Map<String, String> map = RedisUtil.getInstance().hgetAll(CacheNames.QTDCACHE);
		
		List<QTD> lstItem = new ArrayList<QTD>();
		String[] items = map.values().toArray(new String[0]);
		for (int i = 0; i < items.length; i++) {
			lstItem.add(JSONObject.parseObject(items[i], QTD.class));
		}
		
		return lstItem.toArray(new QTD[0]);
	}
	
	public static QTInfo getQTemplate(String name) {
		String attrObj = RedisUtil.getInstance().hget(CacheNames.QTCACHE, name.toLowerCase());
		if (StringUtils.isBlank(attrObj))
			return null;
		
		return JSONObject.parseObject(attrObj, QTInfo.class);
	}
	
	public static QTInfo[] getObjTypeQTs(String name) {
		Map<String, String> map = RedisUtil.getInstance().hgetAll(CacheNames.QTCACHE);
		
		List<QTInfo> lstItem = new ArrayList<QTInfo>();
		String[] items = map.values().toArray(new String[0]);
		for (int i = 0; i < items.length; i++) {
			lstItem.add(JSONObject.parseObject(items[i], QTInfo.class));
		}
		
		return lstItem.toArray(new QTInfo[0]);
	}

	
	public static QTInfo[] getAllQTemplate() {
		Map<String, String> allVols = RedisUtil.getInstance().hgetAll(CacheNames.QTCACHE);
		
		List<QTInfo> lstItem = new ArrayList<QTInfo>();
		String[] items = allVols.values().toArray(new String[0]);
		for (int i = 0; i < items.length; i++) {
			lstItem.add(JSONObject.parseObject(items[i], QTInfo.class));
		}
		
		return lstItem.toArray(new QTInfo[0]);
	}
	

	public static boolean isExistsQT(String name) {
		String json = RedisUtil.getInstance().hget(CacheNames.QTCACHE, name.toLowerCase());
		
		if (StringUtils.isBlank(json))
			return false;
		return true;
	}
	
	private QTDServerCacheUtil() {
	}
	
	private static QTDServerCacheUtil getInstance() {
		if (instance == null) {
			synchronized (QTDServerCacheUtil.class) {
				if (instance == null) {
					instance = new QTDServerCacheUtil();
				}
			}
		}
		
		return instance;
	}
	
	private void initQTD() {
		String sql = "select * from PL_QTEMPLATEDEF t where 1=1";
		try{
			Session session = HibernateSessionFactory.getSession();
			SQLQuery query = session.createSQLQuery(sql);
			List<?> list = query.list();
			for(int i = 0; i < list.size(); i++){
				QTD qtd = new QTD();
				Object[] obj = (Object[]) list.get(i);
				qtd.name = (String)obj[0];
				qtd.creator = (String)obj[1];
				qtd.createTime = ((Date)obj[2]).getTime();
				qtd.btmName = (String)obj[3] == null ? "" : (String)obj[3];
				String abNames = ((String)obj[4]);
				if(abNames == null || abNames.equals("")){
					qtd.abNames = new String[0];
				}else{
					qtd.abNames = ((String)obj[4]).split(",");
				}
				qtd.linkTypeName = (String)obj[5] == null ? "" : (String)obj[5];
				
				setQTD(qtd);
			}
		}catch(Throwable e){
			e.printStackTrace();
			//throw getLocalVciError("PLMQTD-00003", e);
		}
	}
	
	private void initQt() {
		String hsql = "from QTEntity";
		List<QTEntity> qtEntityList = new QTDaoImpl().findEntities(hsql);
		//qts = new QTInfo[qtEntityList.size()];
		for (int i = 0; i < qtEntityList.size(); i++) {
			 QTInfo wapper = getQTWrapper(qtEntityList.get(i));
			 
			 setQTemplate(wapper);
		}
	}
	
	
	private QTInfo getQTWrapper(QTEntity qtEntity){
		if(qtEntity == null){
			return null;
		}
		QTInfo qtWrapper = new QTInfo();
		
		qtWrapper.qtName = qtEntity.getQtName();
		qtWrapper.btmName = qtEntity.getBtmName();
		qtWrapper.creator = qtEntity.getCreator();
		qtWrapper.createTime = qtEntity.getCreateTime().getTime();
		qtWrapper.levelFlag = qtEntity.getLevelFlag();
		String qtUIText = qtEntity.getQtUIText();
		qtWrapper.qtUIText = (qtUIText == null ? "" : qtUIText);
		String qtText = qtEntity.getQtText();
		qtWrapper.qtText = (qtText == null ? "" : qtText);
		
		return qtWrapper;
	}

}