package cn.ksource.web.facade.loginuser;

import java.util.HashMap;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.core.util.JsonUtil;
import cn.ksource.core.util.StringUtil;
import cn.ksource.core.web.PasswordEncoder;

@Service("loginUserFacade")
public class LoginUserFacadeImpl implements LoginUserFacade {
	
	@Autowired
	private BaseDao baseDao;
	
	@Override
	public String updateUserPwd(String userId, String oldPassword,String newPassword) {
		Map map = new HashMap();
		if(!(StringUtil.notEmpty(newPassword)&&StringUtil.isPasswordReg(newPassword)&&StringUtil.notEmpty(oldPassword)&&StringUtil.isPasswordReg(oldPassword))) {
			map.put("status", "0");
			map.put("msg", "密码由6-18位的字母,数字,下划线组成");
			return JsonUtil.map2Json(map);
		}
		oldPassword = oldPassword.trim();
		newPassword = newPassword.trim();
		String sql = "SELECT COUNT(ID) FROM GG_USER WHERE ID = :userId AND PASSWORD = :password";
		int count = baseDao.queryForInteger(sql,new SqlParameter("userId",userId).addValue("password", PasswordEncoder.encode(oldPassword)));
		if(count == 0) {
			map.put("status", "0");
			map.put("msg", "原密码输入错误！");
			return JsonUtil.map2Json(map);
		}
		String updateSql = "UPDATE GG_USER SET PASSWORD = :newPassword WHERE ID = :userId";
		baseDao.execute(updateSql, new SqlParameter("newPassword",PasswordEncoder.encode(newPassword)).addValue("userId", userId));
		map.put("status", "1");
		return JsonUtil.map2Json(map);
	}
	
	@Override
	public String updateUserMobile(String userId, String mobile) {
		
		String sql = "UPDATE GG_USER SET SJHM = :phone,ISPHONE = 2 WHERE ID = :userId";
		baseDao.execute(sql, new SqlParameter("phone",mobile).addValue("userId", userId));
		
		return "1";
	}

	@Override
	public boolean isPhone(String userId, String mobile) {
		String selectSql = "SELECT COUNT(1) FROM GG_USER WHERE ID = :userId AND SJHM = :phone AND ISPHONE = 2";
		Integer count = baseDao.queryForInteger(selectSql,new SqlParameter("userId",userId).addValue("phone", mobile));
		if(count>0){
			return false;
		}else{
			return true;
		}
	}

	@Override
	public boolean isEmail(String userId, String email) {
		String selectSql = "SELECT COUNT(1) FROM GG_USER WHERE ID = :userId AND EMAIL = :phone AND ISEMAIL = 2";
		Integer count = baseDao.queryForInteger(selectSql,new SqlParameter("userId",userId).addValue("phone", email));
		if(count>0){
			return false;
		}else{
			return true;
		}
	}

	@Override
	public String updateUserEmail(String userId, String email) {
		String sql = "UPDATE GG_USER SET EMAIL = :email,ISEMAIL = 2 WHERE ID = :userId";
		baseDao.execute(sql, new SqlParameter("email",email).addValue("userId", userId));
		
		return "1";
	}

	@Override
	public int getUserByPwd(String userId, String pwd) {
		String sql = "SELECT COUNT(ID) FROM GG_USER WHERE ID = :userId AND PASSWORD = :password";
		int count = baseDao.queryForInteger(sql,new SqlParameter("userId",userId).addValue("password", PasswordEncoder.encode(pwd)));
	    return count;
	}

}