package cn.ksource.web.service.impl;

import java.util.List;
import java.util.Map;

import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import cn.ksource.core.config.CacheKeyUtil;
import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.core.util.ConvertUtil;
import cn.ksource.web.service.DataDictionaryService;

@Service("dataDictionaryService")
public class DataDictionaryServiceImpl implements DataDictionaryService {

	private static Logger logger = Logger.getLogger(DataDictionaryServiceImpl.class);
	
	@Autowired
	private BaseDao baseDao;

	@Override
	public Map getAreaById(String areaid) {
		if (StringUtils.isBlank(areaid)) {
			return null;
		}
		Object object = null;
		if (object == null) {
			String sql = "select * from config_data_dictionary_area where id=:areaid";
			object = baseDao.queryForMap(sql,new SqlParameter("areaid",areaid));
			if (object != null) {
				return (Map)object;
			} else {
				return null;
			}
		}
		return (Map)object;
	}

	@Override
	public List<Map> getAreaListByParentID(String parentid) {
		String myPid = null;
		if (StringUtils.isBlank(parentid)) {
			myPid = "0";
		} else {
			myPid = parentid;
		}
		Object object = null;
		if (object == null) {
			String sql = "select ID,ADDRESS_NAME from config_data_dictionary_area where ADDRESS_STATUS=1  ";
			if (StringUtils.isBlank(myPid) || myPid.equalsIgnoreCase("0")) {
				sql += " and  UP_ID is null";
			} else {
				sql += " and  UP_ID=:parentid";
			}
			sql += " order by ADDRESS_SN ";
			List<Map> list  = baseDao.queryForList(sql,new SqlParameter("parentid",myPid));
			if (list != null && !list.isEmpty()) {
				return list;
			} else {
				return null;
			}
		}
		return (List<Map>)object;
	}

	@Override
	public List<Map> getDataDictionaryByCategoryKey(String categoryKey) {
		if (StringUtils.isBlank(categoryKey)) {
			return null;
		}
		Object object = null;
		if (object == null) {
			String sql = "SELECT * FROM CONFIG_DATA_DICTIONARY " +
					"WHERE CATEGORYID=(SELECT ID FROM CONFIG_DATA_DICTIONARY_CATEGORY WHERE CATEGORYKEY=:CATEGORYKEY) AND USESTATE=1 ORDER BY ORDERNUM ";
			List<Map> list  = baseDao.queryForList(sql,new SqlParameter("CATEGORYKEY",categoryKey));
			if (list != null && !list.isEmpty()) {
				return list;
			} else {
				return null;
			}
		}
		return (List<Map>)object;
	}

	@Override
	public Map getDataDictionaryByKey(String dicKey) {
		if (StringUtils.isBlank(dicKey)) {
			return null;
		}
		if (StringUtils.isBlank(dicKey)) {
			return null;
		}
		Object object = null;
		if (object == null) {
			String sql = "select * from CONFIG_DATA_DICTIONARY where DATAKEY=:DATAKEY";
			object = baseDao.queryForMap(sql,new SqlParameter("DATAKEY",dicKey));
			if (object != null) {
				return (Map)object;
			} else {
				return null;
			}
		}
		return (Map)object;
	}

	@Override
	public String getInterfaceUrlByKey(String interfaceKey) {
		if (StringUtils.isBlank(interfaceKey)) {
			return null;
		}
		Object object = null;
		String result = null;
		if (object == null) {
			String sql = 
			"select CONFIG_DATA_SUBSYSTEM.SYSTEMKEY, CONFIG_DATA_INTERFACE.INTERFACEURL \n" +
			"from CONFIG_DATA_INTERFACE,CONFIG_DATA_SUBSYSTEM \n" +
			"WHERE CONFIG_DATA_INTERFACE.SYSTEMID = CONFIG_DATA_SUBSYSTEM.ID\n" +
			"AND CONFIG_DATA_INTERFACE.INTERFACEKEY = :INTERFACEKEY";
			Map map = baseDao.queryForMap(sql,new SqlParameter("INTERFACEKEY",interfaceKey));
			object = map.get("INTERFACEURL");
			if (object != null) {
				result =  getSubSystemUrl(ConvertUtil.obj2Str(map.get("SYSTEMKEY"))) +  object.toString();
				return result;
			} else {
				return null;
			}
		}
		return object.toString();
	}

	@Override
	public String getInterfaceUrlByMessageKey(String messageKey) {
		if (StringUtils.isBlank(messageKey)) {
			return null;
		}
		Object object = null;
		if (object == null) {
			String sql = "select INTERFACEKEY from CONFIG_DATA_MESSAGE where MESSAGE_KEY=:MESSAGE_KEY";
			object = baseDao.queryForString(sql,new SqlParameter("MESSAGE_KEY",messageKey));
			if (object != null) {
				return getInterfaceUrlByKey(object.toString());
			} else {
				return null;     
			}
		} else {
			return getInterfaceUrlByKey(object.toString());
		}
		
	}

	@Override
	public String getSubSystemUrl(String systemKey) {
		if (StringUtils.isBlank(systemKey)) {
			return null;
		}
		Object object = null;
		if (object == null) {
			String sql = "select URL from CONFIG_DATA_SUBSYSTEM where SYSTEMKEY=:SYSTEMKEY";
			object = baseDao.queryForString(sql,new SqlParameter("SYSTEMKEY",systemKey));
			if (object != null) {
				return object.toString();
			} else {
				return null;
			}
		}
		return object.toString();
	}

	@Override
	public void updateAreaById(String areaid) {
		if (StringUtils.isBlank(areaid)) {
			return;
		}
		String sql = "select UP_ID from config_data_dictionary_area where ID=:ID";
		String parentid = baseDao.queryForString(sql,new SqlParameter("ID",areaid));
		updateAreaListByParentID(parentid);
	}

	@Override
	public void updateAreaListByParentID(String parentid) {
		if (StringUtils.isBlank(parentid)) {
			parentid="0";
		}
		logger.info("update area list cache :" + parentid );
	}
	
	
	

	@Override
	public void updateDataDictionaryByCategoryKey(String categoryKey) {
		if (StringUtils.isBlank(categoryKey)) {
			return;
		}
	}

	@Override
	public void updateDataDictionaryByKey(String dicKey) {
		if (StringUtils.isBlank(dicKey)) {
			return;
		}
		String sql = "select CATEGORYKEY from CONFIG_DATA_DICTIONARY_CATEGORY where " +
				"id=(select CATEGORYID from CONFIG_DATA_DICTIONARY where DATAKEY=:DATAKEY)";
		String key = baseDao.queryForString(sql,new SqlParameter("DATAKEY",dicKey));
		updateDataDictionaryByCategoryKey(key);
	}

	@Override
	public void updateInterfaceUrlByKey(String interfaceKey) {
		if (StringUtils.isBlank(interfaceKey)) {
			return;
		}
	}

	@Override
	public void updateInterfaceUrlByMessageKey(String messageKey) {  
		if (StringUtils.isBlank(messageKey)) {
			return;
		}
	}

	@Override
	public void updateSubSystemUrl(String systemKey) {
		if (StringUtils.isBlank(systemKey)) {
			return;
		}
		String sql =
			"select  CONFIG_DATA_INTERFACE.INTERFACEKEY \n" +
			"from CONFIG_DATA_INTERFACE,CONFIG_DATA_SUBSYSTEM \n" +
			"WHERE CONFIG_DATA_INTERFACE.SYSTEMID = CONFIG_DATA_SUBSYSTEM.ID\n" +
			"AND CONFIG_DATA_SUBSYSTEM.SYSTEMKEY = :systemKey";
		List<Map> list = baseDao.queryForList(sql,new SqlParameter("systemKey",systemKey));
		for (Map map : list) {
			updateInterfaceUrlByKey(map.get("INTERFACEKEY").toString());
		}
	}

}