package cn.ksource.web.facade.impl;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.annotation.Resource;

import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;

import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.core.util.ConvertUtil;
import cn.ksource.core.util.DateUtil;
import cn.ksource.core.util.EqualUtil;
import cn.ksource.core.util.JsonUtil;
import cn.ksource.core.util.StringUtil;
import cn.ksource.core.web.OnlineUserListener;
import cn.ksource.web.entity.LoginEntity;
import cn.ksource.web.entity.PermissionEntity;
import cn.ksource.web.facade.BusinessFacade;
import cn.ksource.web.service.UserService;

@Service("businessFacade")
public class BusinessFacadeImpl implements BusinessFacade {

	@Resource(name="baseDao")
	private BaseDao baseDao;
	
	@Autowired
	private UserService userService;
	
	@SuppressWarnings("rawtypes")
	@Override
	public LoginEntity doUserLogin(String loginname, String password,String client_ip) {
		Map userMap = userService.getUserByLoginName(loginname);
		LoginEntity entity = new LoginEntity();
		entity.setUser(userMap);
		//用户名不存在
		if (userMap == null || userMap.isEmpty()) {
			entity.setResult(LoginEntity.Login_Result_UserNameNotExists);
			return entity;
		}
		//用户名或密码错误
		if(!EqualUtil.isStringEqual(userMap.get("PASSWORD"), userService.getEncodedPassword(password))){
			entity.setResult(LoginEntity.Login_Result_PassowrdError);
			return entity;
		}
		//用户被禁用
		if (EqualUtil.isStringEqual(userMap.get("ZT"), "2")) {
			entity.setResult(LoginEntity.Login_Result_LoginForbid);
			return entity;
		}
		
		Map info = baseDao.queryForMap("SELECT * FROM SC_PARTNER_INFO ");
		//判断用户是否过期
		if (ConvertUtil.obj2Long(info.get("VALID_END_DATE")) < DateUtil.getCurrentDate8()) {
			entity.setResult(LoginEntity.Login_Result_LoginTimeOut);
			return entity;
		}
		
		
		//用户已经登录
		if (OnlineUserListener.container.containsKey(userMap.get("ID").toString())) {
			entity.setAlreadyLogined(true);
			return entity;
		}
		
		//于默认密码一致
		if (password.equalsIgnoreCase(userService.getDefaultPwd())) {
			entity.setDefaultPassword(true);
			return entity;
		}
		
		PermissionEntity permissionEntity = userService.getAccessPermission(userMap.get("ID").toString());
		entity.setPermissionEntity(permissionEntity);
		entity.setLoginSuccess(true);
		return entity;
	}
	
	public LoginEntity doChangePwdSubmit(String loginname,String newPwd){
		userService.updatePwd(loginname, newPwd);
		Map userMap = userService.getUserByLoginName(loginname);
		LoginEntity entity = new LoginEntity();
		entity.setUser(userMap);
		//用户已经登录
		if (OnlineUserListener.container.containsKey(userMap.get("ID").toString())) {
			entity.setAlreadyLogined(true);
			return entity;
		}
		PermissionEntity permissionEntity = userService.getAccessPermission(userMap.get("ID").toString());
		entity.setPermissionEntity(permissionEntity);
		entity.setLoginSuccess(true);
		return entity;
	}
	
	public LoginEntity doKickedOutSubmit(String loginname,String client_ip){
		Map userMap = userService.getUserByLoginName(loginname);
		OnlineUserListener.container.get(userMap.get("ID")).invalidate();
		LoginEntity entity = new LoginEntity();
		entity.setUser(userMap);
		
		PermissionEntity permissionEntity = userService.getAccessPermission(userMap.get("ID").toString());
		entity.setPermissionEntity(permissionEntity);
		entity.setLoginSuccess(true);
		
		return entity;
	}
	
	
	public boolean updateUserPwd(String userid,String oldPwd,String newPwd){
		String sql = "SELECT LOGINNAME FROM GG_USER WHERE PASSWORD=:password AND ID=:id";
		String loginname = baseDao.queryForString(sql,new SqlParameter("password",
				userService.getEncodedPassword(oldPwd)).addValue("id", userid));
		if (StringUtils.isBlank(loginname)) {
			return false;
		} else {
			userService.updatePwd(loginname, newPwd);
			return true;
		}
	}
	
	
	@Override
	public Map<String, String> getRoleMapByUserId(String userId) {
		StringBuilder sql = new StringBuilder();
		sql.append("select r.id,r.rolename ");
		sql.append("from ac_role r ");
		sql.append("where exists (select id from ac_user_ref_role u where u.yhbh=:yhbh and u.jsbh=r.id) ");
		
		Map param = new HashMap();
		param.put("yhbh", userId);
		
		List<Map> list = baseDao.queryForList(sql.toString(), param);
		
		Map tMap = new HashMap();
		if (list != null && list.size() > 0) {
			for (Map map : list) {
				tMap.put(map.get("id"), map.get("rolename"));
			}
		}
		return tMap;
	}
	
	@Override
	public Map queryUserMsgByQQ(String openId) {
		String selectSql = "SELECT LOGINNAME FROM GG_USER WHERE QQ_OPEN_ID = :openId";
		Map msg = baseDao.queryForMap(selectSql,new SqlParameter("openId",openId));
		return msg;
	}
	
	@Override
	public LoginEntity doQQUserLogin(String loginname,String client_ip) {
		Map userMap = userService.getUserByLoginName(loginname);
		LoginEntity entity = new LoginEntity();
		entity.setUser(userMap);
		//用户被禁用
		if (EqualUtil.isStringEqual(userMap.get("ZT"), "2")) {
			entity.setResult(LoginEntity.Login_Result_LoginForbid);
			return entity;
		}
		
		Map info = baseDao.queryForMap("SELECT * FROM SC_PARTNER_INFO ");
		//判断用户是否过期
		if (ConvertUtil.obj2Long(info.get("VALID_END_DATE")) < DateUtil.getCurrentDate8()) {
			entity.setResult(LoginEntity.Login_Result_LoginTimeOut);
			return entity;
		}
		
		
		//用户已经登录
		if (OnlineUserListener.container.containsKey(userMap.get("ID").toString())) {
			entity.setAlreadyLogined(true);
			return entity;
		}
		
		
		PermissionEntity permissionEntity = userService.getAccessPermission(userMap.get("ID").toString());
		entity.setPermissionEntity(permissionEntity);
		entity.setLoginSuccess(true);
		
		return entity;
	}
	
	@Override
	public boolean doResetPwd(String username, String email, String password) {
		if(StringUtil.notEmpty(password)) {
			Map paramMap = new HashMap();
			paramMap.put("username", username);
			paramMap.put("email", email);
			String sql = "SELECT ID,LOGINNAME,EMAIL,SJHM FROM GG_USER WHERE LOGINNAME = :username AND (EMAIL = :email OR SJHM = :email)";
			List list =  baseDao.queryForList(sql, paramMap);
			if(null!=list && list.size() == 1) {
				userService.updatePwd(username, password);
				return true;
			} 
		}
		return false;
	}
	
	@Override
	public Map queryUserByName(String loginname){
		Map userMap = userService.getUserByLoginName(loginname);
		return userMap;
	}

	@Override
	public boolean saveData(String relations, String nodes) {
		baseDao.execute("DELETE FROM LARKS_NODES_RELATION",null);
		baseDao.execute("DELETE FROM LARKS_NODES",null);
		if(StringUtil.notEmpty(relations)) {
			String[] rs = relations.split(";");
			String insertSql = "INSERT INTO LARKS_NODES_RELATION(ID,NAME,FROM_ID,TO_ID,EDGE_TYPE) VALUES (:id,:name,:from_id,:to_id,:edge_type)";
			if(null!=rs && rs.length>0) {
				List<SqlParameter> paramsList = new ArrayList<SqlParameter>();
				for(String relation : rs) {
					Map map = JsonUtil.json2Map(relation);
					SqlParameter sqlParameter = new SqlParameter();
					String name = ConvertUtil.obj2StrBlank(map.get("name"));
					String from = ConvertUtil.obj2StrBlank(map.get("fromNode"));
					String to = ConvertUtil.obj2StrBlank(map.get("toNode"));
					String edgeType = ConvertUtil.obj2StrBlank(map.get("edgeType"));
					sqlParameter.addValue("id", StringUtil.getUUID()).addValue("name", name).addValue("from_id", from).addValue("to_id", to).addValue("edge_type", edgeType);
					paramsList.add(sqlParameter);
				}
				
				baseDao.executeBatch(insertSql, paramsList);
			}
		}
		if(StringUtil.notEmpty(nodes)) {
			String insertSql = "INSERT INTO LARKS_NODES(ID,NAME,IMAGE,XLOT,YLOT) VALUES (:id,:name,:image,:xlot,:ylot)";
			String[] ns = nodes.split(";");
			if(null!=ns && ns.length>0) {
				List<SqlParameter> paramsList = new ArrayList<SqlParameter>();
				for(String node : ns) {
					Map map = JsonUtil.json2Map(node);
					SqlParameter sqlParameter = new SqlParameter();
					String id = ConvertUtil.obj2StrBlank(map.get("id"));
					String name = ConvertUtil.obj2StrBlank(map.get("name"));
					String image = ConvertUtil.obj2StrBlank(map.get("imageType"));
					String xlot = ConvertUtil.obj2StrBlank(map.get("xlot"));
					String ylot = ConvertUtil.obj2StrBlank(map.get("ylot"));
					sqlParameter.addValue("id", id).addValue("name", name).addValue("image", image).addValue("xlot", xlot).addValue("ylot", ylot);
					paramsList.add(sqlParameter);
				}
				baseDao.executeBatch(insertSql, paramsList);
			}
		}
		return true;
	}

	@Override
	public String getJsonData() {
		Map result = new HashMap();
		String nodeSql = "SELECT id,name,image,xlot as x,ylot as y FROM LARKS_NODES ";
		List<Map> nodes = baseDao.queryForList(nodeSql);
		result.put("nodes", nodes);
		
		String relationSql = "SELECT id,name,from_id,to_id,edge_type FROM LARKS_NODES_RELATION";
		List<Map> relations = baseDao.queryForList(relationSql);
		result.put("relations", relations);
		String json = JsonUtil.map2Json(result);
		return json;
	}

	@Override
	public Map queryUserMsgByWechat(String openId) {
		String selectSql = "SELECT LOGINNAME FROM GG_USER WHERE WECHAT_LOGIN_OPEN_ID = :openId";
		Map msg = baseDao.queryForMap(selectSql,new SqlParameter("openId",openId));
		return msg;
	}

	private static int a = 1;
	@Override
	@Cacheable(value="WeiXinCache")
	public String testEhache() {
		a++;
		return String.valueOf(a);
	}

	@Override
	public void updatePartnerInfo(String endDate, Long curDate) {
		SqlParameter param = new SqlParameter();
		param.addValue("endDate", endDate);
		param.addValue("curDate", curDate);
		String sql = " update sc_partner_info set valid_end_date=:endDate,lc_up_time=:curDate ";
		baseDao.execute(sql, param);
	}

	@Override
	public String getV() {
		String sql="select VERSION_CODE from LARKS_PLATFORM_VERSION where STATUS=1";
		String VERSION_CODE=baseDao.queryForString(sql);
		return VERSION_CODE;
	}

}