package cn.ksource.web.facade.uc.login;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
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.ConvertUtil;
|
import cn.ksource.core.util.StringUtil;
|
import cn.ksource.core.web.PasswordEncoder;
|
import cn.ksource.core.web.WebLoginUser;
|
import cn.ksource.web.SysConstants;
|
import cn.ksource.web.entity.WebLoginEntity;
|
|
@Service("userFacade")
|
@SuppressWarnings("unchecked")
|
public class UserFacadeImpl implements UserFacade {
|
|
@Autowired
|
private BaseDao baseDao;
|
|
@Override
|
public Map queryUserByName(String username) {
|
Map resultMap = new HashMap();
|
if(StringUtil.notEmpty(username)) {
|
//StringBuilder builder = new StringBuilder("SELECT A.*,B.CUSTOMER_NAME,B.PARTNER_ID FROM SC_PARTNER_CUSTOMER_ACCOUNT_INFO A,SC_PARTNER_CUSTOMER_INFO B WHERE A.CUSTOMER_ID = B.ID AND LOGIN_NAME = :username");
|
String selectSql = "SELECT A.*,B.CUSTOMER_STATE,B.CREATE_TIME,B.VALID_BEGIN_DATE,B.VALID_END_DATE,B.CUSTOMER_NAME,B.SHORT_NAME,B.CUSTOMER_STATE FROM CUSTOMER_CONTACTS A,SC_PARTNER_CUSTOMER_INFO B WHERE A.CUSTOMER_ID = B.ID AND A.LOGIN_NAME = :username";
|
resultMap = baseDao.queryForMap(selectSql,new SqlParameter().addValue("username", username));
|
|
}
|
return resultMap;
|
}
|
|
|
@Override
|
public int queryHasUser(String username) {
|
if(StringUtil.notEmpty(username)) {
|
StringBuilder sql = new StringBuilder("SELECT COUNT(ID) FROM CUSTOMER_INFO WHERE CUSTOMER_NAME = :username ");
|
Map paramMap = new HashMap();
|
paramMap.put("username", username);
|
|
String registerPeople = "SELECT COUNT(ID) FROM CRM_NEW_REGISTER_POOL WHERE COMPANY_NAME = :username ";
|
|
int count1 = baseDao.queryForInteger(sql.toString(), paramMap);
|
int count2 = baseDao.queryForInteger(registerPeople,paramMap);
|
return count1+count2;
|
}
|
return 0;
|
}
|
|
|
@Override
|
public WebLoginEntity doUserLogin(HttpServletRequest request,String username, String password) {
|
WebLoginEntity loginEntity = new WebLoginEntity();
|
//用户名为空
|
if(!StringUtil.notEmpty(username)) {
|
loginEntity.setResult(WebLoginEntity.LOGIN_RESULT_USERNAME_IS_EMPTY);
|
return loginEntity;
|
}
|
//密码为空
|
if(!StringUtil.notEmpty(password)) {
|
loginEntity.setResult(WebLoginEntity.LOGIN_RESULT_PASSWORD_IS_EMPTY);
|
return loginEntity;
|
}
|
Map map = new HashMap();
|
map = queryUserByName(username.trim());
|
//用户名不存在
|
if (null == map || map.isEmpty()) {
|
loginEntity.setResult(WebLoginEntity.Login_Result_UserNameNotExists);
|
return loginEntity;
|
}
|
|
String pwd = ConvertUtil.obj2StrBlank(map.get("PASSWORD"));
|
//密码错误
|
if (!PasswordEncoder.encode(password.trim()).equals(pwd)) {
|
loginEntity.setResult(WebLoginEntity.Login_Result_PassowrdError);
|
return loginEntity;
|
}
|
//账号被锁定，请联系管理员
|
if(ConvertUtil.obj2StrBlank(map.get("STATE")).equals("2")){
|
loginEntity.setResult(WebLoginEntity.Login_Result_Lock);
|
return loginEntity;
|
}
|
|
|
//账号不允许登录
|
if(ConvertUtil.obj2StrBlank(map.get("ALLOW_LOGIN")).equals("2")) {
|
loginEntity.setResult(WebLoginEntity.Login_Result_Lock);
|
return loginEntity;
|
}
|
//判断登录的联系人所属的客户是否被禁用
|
if(ConvertUtil.obj2StrBlank(map.get("CUSTOMER_STATE")).equals("2")){
|
loginEntity.setResult(WebLoginEntity.Login_Customer_Disable);
|
return loginEntity;
|
}
|
|
String isTimeOut = ConvertUtil.obj2StrBlank(map.get("IS_TIME_OUT"));
|
if(StringUtil.notEmpty(isTimeOut) && isTimeOut.equals("2")) {
|
loginEntity.setResult(WebLoginEntity.Login_out_time);
|
return loginEntity;
|
}
|
|
//判断当前用户密码是否和初始化密码一致
|
if(PasswordEncoder.encode(SysConstants.default_Password).equals(pwd)) {
|
loginEntity.setResult(WebLoginEntity.Login_Result_InitPwd);
|
} else {
|
loginEntity.setResult(WebLoginEntity.LOGIN_RESULT_SUCCESSED);
|
}
|
|
|
String userId = ConvertUtil.obj2StrBlank(map.get("ID"));
|
String userName = ConvertUtil.obj2StrBlank(map.get("CONTACT_NAME"));
|
String customerId = ConvertUtil.obj2StrBlank(map.get("CUSTOMER_ID"));
|
String customerName = ConvertUtil.obj2StrBlank(map.get("CUSTOMER_NAME"));
|
String isEmail = ConvertUtil.obj2StrBlank(map.get("ISEMAIL"));
|
String isPhone = ConvertUtil.obj2StrBlank(map.get("ISPHONE"));
|
String partnerId = ConvertUtil.obj2StrBlank(map.get("PARTNER_ID"));
|
|
WebLoginUser loginUser = new WebLoginUser(userId,userName,customerId,customerName,isEmail,isPhone);
|
loginEntity.setUser(loginUser);
|
|
request.getSession().setAttribute(SysConstants.WEBSITE_LOGIN_INFO_KEY, loginUser);
|
|
|
|
return loginEntity;
|
}
|
|
|
@Override
|
public boolean doResetPwd(String username, String mobile, String password) {
|
if(StringUtil.notEmpty(password)) {
|
Map paramMap = new HashMap();
|
paramMap.put("username", username);
|
paramMap.put("mobile", mobile);
|
String sql = "SELECT ID,LOGIN_NAME FROM CUSTOMER_CONTACTS WHERE LOGIN_NAME = :username AND MOBILE = :mobile";
|
List list = baseDao.queryForList(sql, paramMap);
|
if(null!=list && list.size() == 1) {
|
paramMap.put("password", PasswordEncoder.encode(password));
|
String updateSql = "UPDATE CUSTOMER_CONTACTS SET PASSWORD = :password WHERE LOGIN_NAME = :username AND MOBILE = :mobile";
|
baseDao.execute(updateSql, paramMap);
|
return true;
|
}
|
}
|
return false;
|
}
|
|
|
}
|
