package cn.ksource.web.facade.impl;

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

import javax.servlet.http.HttpServletRequest;

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

import cn.ksource.beans.GG_USER;
import cn.ksource.beans.GG_ZZJG;
import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.core.page.PageInfo;
import cn.ksource.core.util.DefaultUtil;
import cn.ksource.core.util.EqualUtil;
import cn.ksource.core.util.JsonUtil;
import cn.ksource.core.util.StringUtil;
import cn.ksource.core.web.PasswordEncoder;
import cn.ksource.core.web.TreeNode;
import cn.ksource.core.web.WebUtil;
import cn.ksource.web.facade.YhglFacade;
import cn.ksource.web.service.UserService;
import cn.ksource.web.service.ZzjgService;


@Service("yhglFacade")
public class YhglFacadeImpl implements YhglFacade {

	@Autowired
	private BaseDao baseDao;

	@Autowired
	private ZzjgService zzjgService;
	
	@Autowired
	private UserService userService;

	@Override
	public TreeNode getZzjgTree() {
		return zzjgService.getZzjgTree();
	}

	@Override
	public List<Map> getBmUserList(String bmbh) {
		
		String sql = "SELECT * FROM GG_USER WHERE 1=1 ";
		
		if (StringUtils.isNotBlank(bmbh) && !bmbh.toString().equalsIgnoreCase("0")) {
			sql += " AND SSBMBH=:bmbh ";
		} else {
			
		}
		sql += " ORDER BY ACCOUNTTYPE asc ";
		
		List<Map> list = baseDao.queryForList(sql,new SqlParameter("bmbh",bmbh));
		
		/*for (Map map : list) {
			map.put("LOGINTYPE", DefaultUtil.defautIfTrue(EqualUtil.isStringEqual(map.get("LOGINTYPE"), "1"), "密码登录", "USBKey登录"));
			map.put("ACCOUNTTYPE", DefaultUtil.defautIfTrue(EqualUtil.isStringEqual(map.get("ACCOUNTTYPE"), "1"), "领导帐号", "工作人员"));
		}*/
		
		return list;
	}

	@Override
	public void execInitUserPwd(String userid,String loginname) {
		userService.updatePwd(loginname, userService.getDefaultPwd());
	}

	@Override
	public void execDisableUser(String userid,String status) {
		GG_USER user = new GG_USER(userid);
		user.setZt(Integer.valueOf(status));
		user.update();
		/*userService.updateUserInfoCache(loginname);*/
	}

	@Override
	public boolean isLoginNameExists(String loginname) {
		return userService.isLoginNameExists(loginname);
	}

	@Override
	public GG_USER addOrUpdateGG_USER(GG_USER user) {
		if (StringUtils.isBlank(user.getId())) {
			user.setZt(1);
			user.setZhlx(2);    
			user.setKm_score(0);
			user.setPassword(PasswordEncoder.encode("88888888"));
		}
		System.out.println(user.getSsbmbh());   
		GG_ZZJG ssbm = new GG_ZZJG(user.getSsbmbh()).getInstanceById();
		user.setSscj(ssbm.getCengj());    
		
		if (user.getSscj().intValue() == 4) {
			user.setSijbmbh(user.getSsbmbh());
			user.setSjbmbh(ssbm.getSjbh());
			user.setEjbmbh(new GG_ZZJG(user.getSjbmbh()).getInstanceById().getSjbh());
			user.setYjbmbh(new GG_ZZJG(user.getEjbmbh()).getInstanceById().getSjbh());
		}
		if (user.getSscj().intValue() == 3) {
			user.setSijbmbh(null);
			user.setSjbmbh(user.getSsbmbh());
			user.setEjbmbh(ssbm.getSjbh());
			user.setYjbmbh(new GG_ZZJG(user.getEjbmbh()).getInstanceById().getSjbh());
		}
		if (user.getSscj().intValue() == 2) {
			user.setSijbmbh(null);
			user.setSjbmbh(null);
			user.setEjbmbh(user.getSsbmbh());
			user.setYjbmbh(ssbm.getSjbh());
		}
		if (user.getSscj().intValue() == 1) {
			user.setSijbmbh(null);
			user.setSjbmbh(null);
			user.setEjbmbh(null);
			user.setYjbmbh(user.getSsbmbh());
		}
		user.insertOrUpdate();
		return user;
	}

	@Override
	public List<Map> queryBmTree(HttpServletRequest request) {
		Map paramMap = new HashMap();
		String selectSubSql = "SELECT * FROM GG_ZZJG WHERE  ZT = 1  ORDER BY CENGJ,SXH ";
		List<Map> cates = baseDao.queryForList(selectSubSql,paramMap);
        Map result = new HashMap();
		
		List<Map> resultList = new LinkedList<Map>();
		
		Map<String, Map> yjgnCache = new HashMap<String, Map>();
		
		for (Map map : cates) {
			String cengji = map.get("CENGJ").toString();
			//一级树
			if (cengji.equalsIgnoreCase("1")) {
				yjgnCache.put(map.get("ID").toString(), map);
				List<Map> ejgnList = new LinkedList<Map>();
				map.put("ejTree", ejgnList);
				resultList.add(map);
				continue;
			}
			//二级树
			if (cengji.equalsIgnoreCase("2")) {
				String pId = map.get("SJBH").toString();
				if(yjgnCache.containsKey(pId)) {
					Map yjgnMap = yjgnCache.get(pId);
					List<Map> list = (List<Map>)yjgnMap.get("ejTree");
					list.add(map);
				}
			}
		}
		System.out.println(JsonUtil.list2Json(resultList));
		return resultList;
	}

	@Override
	public int yhCount(Map<String,String> params) {
		StringBuilder builder = new StringBuilder("SELECT COUNT(A.ID) FROM GG_USER A LEFT JOIN GG_ZZJG B ON A.SSBMBH = B.ID  WHERE 1=1 ");
		Map paramMap = new HashMap();
		String bmId = params.get("bmId");
		if(StringUtil.notEmpty(bmId)) {
			builder.append(" AND A.SSBMBH = :bmId ");
			paramMap.put("bmId", bmId);
		}
		
		String zsxm = params.get("zsxm");
		if(StringUtil.notEmpty(zsxm)) {
			builder.append(" AND A.ZSXM LIKE :zsxm ");
			paramMap.put("zsxm", "%"+zsxm+"%");
		}
		
		String sjhm = params.get("sjhm");
		if(StringUtil.notEmpty(sjhm)) {
			builder.append(" AND A.SJHM like :sjhm ");
			paramMap.put("sjhm", "%"+sjhm+"%");
		}
		
		String deskid = params.get("deskid");
		if(StringUtil.notEmpty(deskid)) {
			builder.append(" AND A.DESKID = :deskid ");
			paramMap.put("deskid", deskid);
		}
		
		String zt = params.get("zt");
		if(StringUtil.notEmpty(zt)) {
			builder.append(" AND A.ZT = :zt ");
			paramMap.put("zt", zt);
		}
		
		int count = baseDao.queryForInteger(builder.toString(), paramMap);
		return count;
	}

	@Override
	public PageInfo yhData(PageInfo pageInfo,Map<String,String> params) {
		StringBuilder builder = new StringBuilder("SELECT A.*,B.ID BMID,B.JGMC,B.ZT BMSTATE FROM GG_USER A LEFT JOIN GG_ZZJG B ON A.SSBMBH = B.ID WHERE 1 = 1 ");
		Map paramMap = new HashMap();
		String bmId = params.get("bmId");
		if(StringUtil.notEmpty(bmId)) {
			builder.append(" AND A.SSBMBH = :bmId ");
			paramMap.put("bmId", bmId);
		}
		
		String zsxm = params.get("zsxm");
		if(StringUtil.notEmpty(zsxm)) {
			builder.append(" AND A.ZSXM LIKE :zsxm ");
			paramMap.put("zsxm", "%"+zsxm+"%");
		}
		
		String sjhm = params.get("sjhm");
		if(StringUtil.notEmpty(sjhm)) {
			builder.append(" AND A.SJHM like :sjhm ");
			paramMap.put("sjhm", "%"+sjhm+"%");
		}
		
		String zt = params.get("zt");
		if(StringUtil.notEmpty(zt)) {
			builder.append(" AND A.ZT = :zt ");
			paramMap.put("zt", zt);
		}
		
		builder.append(" ORDER BY A.LOGINNAME ");
		
		PageInfo info = baseDao.queryforSplitPageInfo(pageInfo, builder.toString(), paramMap);
	
		return info;
	}

	@Override
	public PageInfo userListData(PageInfo pageInfo, String bmId) {
		Map<String,Object> support = getUserListSupportMap(bmId);
		String sql = support.get("sql").toString();
		Map param = (Map)support.get("param");
		PageInfo info = baseDao.queryforSplitPageInfo(pageInfo, sql, param);
		return info;
	}

	@Override
	public int userListCount(String bmId) {
		Map<String,Object> support = getUserListSupportMap(bmId);
		String sql = " select count(*) from ( " + support.get("sql").toString() + " ) t";
		Map param = (Map)support.get("param");
		int count = baseDao.queryForInteger(sql.toString(), param);
		return count;
	}
	
	private Map<String,Object> getUserListSupportMap(String bmId){
		Map<String,Object> support = new HashMap<String,Object>();
		StringBuilder sql = new StringBuilder("SELECT A.* FROM GG_USER A  WHERE 1=1 AND ZT=1 ");
		Map<String,String> param = new HashMap<String,String>();
		if(StringUtil.notEmpty(bmId)) {
			sql.append(" AND A.SSBMBH = :bmId ");
			param.put("bmId", bmId);
		}
		sql.append(" ORDER BY A.LOGINNAME ");
		support.put("sql", sql.toString());
		support.put("param", param);
		return support;
	}

	@Override
	public Map queryfordesktop() {
        List<Map> list = baseDao.queryForList("select A.ID,A.DESKTOP_NAME from GG_DESKTOP A");
		
		Map deskMap = new HashMap();
		for(Map map : list) {
			deskMap.put(map.get("ID"), map.get("DESKTOP_NAME"));
		}
		return deskMap;
	}

	@Override
	public Map queryPartnerUserNum() {
		Map resultMap = new HashMap();
		String selectSql = "SELECT COUNT(ID) FROM GG_USER WHERE ZT=1  ";
		int count = baseDao.queryForInteger(selectSql);
		
		//查询该加盟商下最多可以添加多少员工
		String selectUser = "SELECT USER_ACCOUNT_NUM FROM SC_PARTNER_INFO  ";
		int moreNum = baseDao.queryForInteger(selectUser);
		
		if(moreNum>count) {
			resultMap.put("result", 1);
		} else {
			resultMap.put("result", 2);
		}
		resultMap.put("nowNum", count);
		resultMap.put("maxNum", moreNum);
		return resultMap;
	}
	
	@Override
	public Map queryUserDetail(String id) {
		String selectSql = " SELECT A.*,B.DESKTOP_NAME FROM GG_USER A LEFT JOIN GG_DESKTOP B ON A.DESKID = B.ID WHERE A.ID = :userId ";
		
		Map user = baseDao.queryForMap(selectSql,new SqlParameter("userId",id));
		return user;
	}
}