package project.user.internal;
|
|
import java.util.Date;
|
import java.util.Iterator;
|
import java.util.Map;
|
import java.util.Set;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
import org.apache.commons.lang3.ObjectUtils;
|
import org.springframework.security.providers.encoding.PasswordEncoder;
|
|
import kernel.exception.BusinessException;
|
import kernel.util.StringUtils;
|
import kernel.web.ApplicationUtil;
|
import project.Constants;
|
import project.party.PartyService;
|
import project.party.model.Party;
|
import project.syspara.Syspara;
|
import project.syspara.SysparaService;
|
import project.user.UserService;
|
import project.user.idcode.IdentifyingCodeTimeWindowService;
|
import security.Role;
|
import security.SecUser;
|
import security.internal.SecUserService;
|
|
public class UserServiceImpl implements UserService {
|
|
private PartyService partyService;
|
|
private SecUserService secUserService;
|
|
private PasswordEncoder passwordEncoder;
|
|
private OnlineUserService onlineUserService;
|
|
private IdentifyingCodeTimeWindowService identifyingCodeTimeWindowService;
|
|
/**
|
* 图片验证key，保证前后一致性
|
*/
|
private Map<String, String> imageCodeCache = new ConcurrentHashMap<String, String>();
|
|
@Override
|
public SecUser login(String username, String password) {
|
SecUser user = secUserService.findUserByLoginName(username);
|
SysparaService sysparaService = ApplicationUtil.getBean(SysparaService.class);
|
Syspara syspara = sysparaService.find("bind_email_phone_login");
|
if(ObjectUtils.isNotEmpty(syspara)&&"1".equals(syspara.getValue())) {
|
user = secUserService.findUserByLoginName2(username);
|
}
|
if (user == null) {
|
throw new BusinessException("用户不存在");
|
}
|
Party party = partyService.cachePartyBy(user.getPartyId(), false);
|
String[] rolesArrty = new String[] { Constants.SECURITY_ROLE_GUEST, Constants.SECURITY_ROLE_MEMBER, Constants.SECURITY_ROLE_TEST };
|
if (party == null || !party.getLogin_authority()) {
|
throw new BusinessException("登录失败");
|
}
|
Set<Role> roles = user.getRoles();
|
boolean find = false;
|
for (Iterator<Role> iterator = roles.iterator(); iterator.hasNext();) {
|
Role role = (Role) iterator.next();
|
for (int i = 0; i < rolesArrty.length; i++) {
|
if (role.getRoleName().equals(rolesArrty[i])) {
|
find = true;
|
}
|
}
|
}
|
|
if (!find) {
|
throw new BusinessException("登录失败");
|
}
|
String password_encoder = passwordEncoder.encodePassword(password, user.getUsername());
|
|
if (!password_encoder.equals(user.getPassword())) {
|
throw new BusinessException("密码不正确");
|
}
|
|
party.setLast_loginTime(new Date());
|
partyService.update(party);
|
|
return user;
|
|
}
|
|
/**
|
* 验证码登录
|
*/
|
@Override
|
public SecUser login_idcode(String username, String verifcode) {
|
SecUser user = secUserService.findUserByLoginName(username);
|
|
if (user == null) {
|
throw new BusinessException("用户名不存在");
|
}
|
Party party = partyService.cachePartyBy(user.getPartyId(), false);
|
String[] rolesArrty = new String[] {};
|
if (party == null || !party.getLogin_authority()) {
|
throw new BusinessException("登录失败");
|
}
|
Set<Role> roles = user.getRoles();
|
boolean find = false;
|
for (Iterator<Role> iterator = roles.iterator(); iterator.hasNext();) {
|
Role role = (Role) iterator.next();
|
for (int i = 0; i < rolesArrty.length; i++) {
|
if (role.getRoleName().equals(rolesArrty[i])) {
|
find = true;
|
}
|
}
|
}
|
|
if (!find) {
|
throw new BusinessException("登录失败");
|
}
|
|
String authcode = this.identifyingCodeTimeWindowService.getAuthCode(username);
|
|
if ((authcode == null) || (!authcode.equals(verifcode))) {
|
throw new BusinessException("登录失败");
|
}
|
this.identifyingCodeTimeWindowService.delAuthCode(username);
|
return user;
|
}
|
|
@Override
|
public void online(String partyId) {
|
if (StringUtils.isNullOrEmpty(partyId)) {
|
return;
|
}
|
onlineUserService.put(partyId, new Date());
|
}
|
|
@Override
|
public void logout(String partyId) {
|
if (StringUtils.isNullOrEmpty(partyId)) {
|
return;
|
}
|
onlineUserService.del(partyId);
|
}
|
|
@Override
|
public boolean isOnline(String partyId) {
|
Object object = onlineUserService.get(partyId);
|
if (object != null) {
|
return true;
|
}
|
return false;
|
}
|
|
public void setSecUserService(SecUserService secUserService) {
|
this.secUserService = secUserService;
|
}
|
|
public void setPasswordEncoder(PasswordEncoder passwordEncoder) {
|
this.passwordEncoder = passwordEncoder;
|
}
|
|
public void setPartyService(PartyService partyService) {
|
this.partyService = partyService;
|
}
|
|
public Map<String, String> getImageCodeCache() {
|
return imageCodeCache;
|
}
|
|
public void putImageCode(String key, String value) {
|
imageCodeCache.put(key, value);
|
}
|
|
public String cacheImageCode(String key) {
|
return imageCodeCache.get(key);
|
}
|
|
public void cacheRemoveImageCode(String key) {
|
imageCodeCache.remove(key);
|
}
|
|
public void putRandKey(String key, String value) {
|
imageCodeCache.put(key, value);
|
}
|
|
public IdentifyingCodeTimeWindowService getIdentifyingCodeTimeWindowService() {
|
return identifyingCodeTimeWindowService;
|
}
|
|
public void setIdentifyingCodeTimeWindowService(IdentifyingCodeTimeWindowService identifyingCodeTimeWindowService) {
|
this.identifyingCodeTimeWindowService = identifyingCodeTimeWindowService;
|
}
|
|
public void setOnlineUserService(OnlineUserService onlineUserService) {
|
this.onlineUserService = onlineUserService;
|
}
|
}
|
