package com.ld.igds.phone.service.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.bstek.bdf2.core.model.DefaultDept;
|
import com.bstek.bdf2.core.model.DefaultUser;
|
import com.bstek.dorado.core.Configure;
|
import com.ld.igds.common.CoreCommonService;
|
import com.ld.igds.constant.RespCodeEnum;
|
import com.ld.igds.models.DicSysConf;
|
import com.ld.igds.phone.constant.PhoneConstant;
|
import com.ld.igds.phone.dto.AuthUser;
|
import com.ld.igds.phone.dto.DtoUser;
|
import com.ld.igds.phone.dto.PhoneResponse;
|
import com.ld.igds.phone.mapper.PhoneCommonMapper;
|
import com.ld.igds.phone.param.ParamUser;
|
import com.ld.igds.phone.param.PhoneRequest;
|
import com.ld.igds.phone.service.PhoneService;
|
import com.ld.igds.phone.util.PhoneRespUtil;
|
import com.ld.igds.phone.util.PhoneUtil;
|
import com.ld.igds.sys.service.SysDeptService;
|
import com.ld.igds.util.ContextUtil;
|
import com.ld.igds.util.RedisUtil;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.security.authentication.encoding.PasswordEncoder;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 登录接口实现
|
*
|
* @author chen
|
*/
|
@Service
|
public class ServiceImpl5001 implements PhoneService {
|
@Autowired
|
private PhoneCommonMapper phoneCommonMapper;
|
@Autowired
|
private RedisUtil redisUtil;
|
|
@SuppressWarnings("deprecation")
|
@Resource(name = "bdf2.passwordEncoder")
|
private PasswordEncoder passwordEncoder;
|
|
@Autowired
|
private SysDeptService deptService;
|
|
@Autowired
|
private CoreCommonService coreCommonService;
|
|
@Override
|
public String getInterfaceId() {
|
return PhoneConstant.API_PHONE_5001;
|
}
|
|
@SuppressWarnings("unchecked")
|
@Override
|
public PhoneResponse<Object> execute(PhoneRequest<JSONObject> req, AuthUser auth)
|
throws Exception {
|
ParamUser param = JSONObject.parseObject(req.getData().toString(), ParamUser.class);
|
|
//验证参数
|
if (null == param) {
|
return PhoneRespUtil.error(RespCodeEnum.CODE_1007, "登录名和密码为空，请核查！");
|
}
|
if (StringUtils.isEmpty(param.getUsername())) {
|
return PhoneRespUtil.error(RespCodeEnum.CODE_1007, "用户名不能为空，请输入后重新登陆！");
|
}
|
if (StringUtils.isEmpty(param.getPassword())) {
|
return PhoneRespUtil.error(RespCodeEnum.CODE_1007, "密码不能为空，请输入后重新登陆！");
|
}
|
|
//查询用户并验证
|
DefaultUser user = phoneCommonMapper.phoneGetUser(param.getUsername());
|
if (null == user) {
|
return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "系统无当前用户，请核查后重新登录！");
|
}
|
//判断用户是否离职
|
if (!user.isEnabled()) {
|
return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "当前账号已离职，无法登陆！");
|
}
|
|
boolean flag = this.check(param, user);
|
if (!flag) {
|
return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "用户名和密码错误，请重新登录！");
|
}
|
|
DicSysConf sysConf = coreCommonService.getCacheSysConf(user.getCompanyId());
|
|
DtoUser dtoUser = new DtoUser();
|
//设置用户信息
|
dtoUser.setCname(user.getCname());
|
dtoUser.setMobile(user.getMobile());
|
dtoUser.setUsername(user.getUsername());
|
dtoUser.setTokenAuth(ContextUtil.getUUID());
|
//设置售后信息
|
dtoUser.setSupport(sysConf.getSupport());
|
dtoUser.setEmail(sysConf.getEmail());
|
dtoUser.setPhone(sysConf.getPhone());
|
dtoUser.setWebsite(sysConf.getWebsite());
|
dtoUser.setAddress(sysConf.getAddress());
|
//设置版本信息
|
dtoUser.setVersions("V3.0");
|
Map<String, String> metaData = new HashMap<>();
|
String threeUrl = Configure.getString("default.threeUrl");
|
threeUrl = StringUtils.isEmpty(threeUrl) ? "" : "igds/" + threeUrl;
|
metaData.put("threeUrl", threeUrl);
|
dtoUser.setMetaData(metaData);
|
|
//设置AuthUser信息到缓存
|
AuthUser authUser = new AuthUser();
|
authUser.setCompanyId(user.getCompanyId());
|
authUser.setUsername(user.getUsername());
|
authUser.setCname(user.getCname());
|
// authUser.setAddress(user.getAddress());
|
authUser.setEmail(user.getEmail());
|
authUser.setMobile(user.getMobile());
|
//设置登录用户所属分库信息
|
List<DefaultDept> depts = deptService.loadUserDepts(user.getUsername());
|
if (null != depts && depts.size() > 0) {
|
authUser.setDeptId(depts.get(0).getId());
|
authUser.setDeptName(depts.get(0).getName());
|
}
|
|
redisUtil.set(PhoneUtil.createKey(dtoUser.getTokenAuth()),
|
authUser, 60 * 60 * 24);
|
|
return PhoneRespUtil.success(dtoUser, req);
|
|
}
|
|
/**
|
* 验证用户名和密码
|
*
|
* @param param
|
* @param user
|
* @return
|
*/
|
private boolean check(ParamUser param, DefaultUser user) {
|
boolean flag = passwordEncoder.isPasswordValid(user.getPassword(), param.getPassword(), user.getSalt());
|
if (param.getUsername().equals(user.getUsername()) && flag) {
|
return true;
|
}
|
return false;
|
}
|
}
|
