package com.xzx.gc.role.service;
|
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.RandomUtil;
|
import com.fasterxml.jackson.databind.DeserializationFeature;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.xzx.gc.common.constant.CommonEnum;
|
import com.xzx.gc.common.constant.Constants;
|
import com.xzx.gc.common.dto.log.OperationAppLog;
|
import com.xzx.gc.common.exception.PlatformException;
|
import com.xzx.gc.common.exception.RestException;
|
import com.xzx.gc.common.utils.BusinessUtil;
|
import com.xzx.gc.common.utils.SecurityUtil;
|
import com.xzx.gc.entity.*;
|
import com.xzx.gc.model.ExceptionEnum;
|
import com.xzx.gc.model.JsonResult;
|
import com.xzx.gc.model.MiException;
|
import com.xzx.gc.role.mapper.CityPartnerMapper;
|
import com.xzx.gc.role.mapper.CoreOrgMapper;
|
import com.xzx.gc.role.mapper.CoreUserMapper;
|
import com.xzx.gc.role.model.CoreUserModel;
|
import com.xzx.gc.role.rbac.UserLoginInfoAdmin;
|
import com.xzx.gc.util.BeanUtils;
|
import com.xzx.gc.util.enums.DelFlagEnum;
|
import com.xzx.gc.util.enums.GeneralStateEnum;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import tk.mybatis.mapper.entity.Example;
|
|
import javax.validation.constraints.NotBlank;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Service
|
@Transactional
|
public class CoreUserService {
|
@Autowired
|
CoreUserMapper userMapper ;
|
@Autowired
|
CityPartnerMapper partnerMapper ;
|
@Autowired
|
PartnerGaodeService gaodeService;
|
@Autowired
|
AddressLevelService addressLevelService;
|
@Autowired
|
CoreOrgMapper orgMapper;
|
|
@Autowired
|
private CityPartnerMapper cityPartnerMapper;
|
|
@Autowired
|
private CoreRoleService coreRoleService;
|
|
@Autowired
|
private CoreUserRoleService coreUserRoleService;
|
|
@Autowired
|
private CityPartnerService cityPartnerService;
|
|
|
|
public UserLoginInfoAdmin login(String userName, String password){
|
CoreUser query = new CoreUser();
|
query.setCode(userName);
|
query.setPassword(password);
|
|
CoreUser user =userMapper.selectOne(query);
|
if(user==null) {
|
throw new RestException("用户"+"不存在或者密码错误");
|
}
|
if(!user.getState().equals(GeneralStateEnum.ENABLE.getValue())){
|
throw new RestException("用户"+"已经失效");
|
}
|
if(user.getDelFlag()== DelFlagEnum.DELETED.getValue()) {
|
throw new RestException("用户"+"已经删除");
|
}
|
|
|
List<CoreOrg> orgs = getUserOrg(user.getId(),user.getOrgId());
|
UserLoginInfoAdmin loginInfo = new UserLoginInfoAdmin();
|
loginInfo.setOrgs(orgs);
|
loginInfo.setUser(user);
|
return loginInfo;
|
|
}
|
|
public Map<String,Object> loginApi(String userName, String password,String userType){
|
Map<String,Object> map = new HashMap<>();
|
String msg = "";
|
CoreUser query = new CoreUser();
|
List<Map<String,Object>> cityTown=new ArrayList<>();
|
Example example = new Example(CoreUser.class);
|
Example.Criteria criteria = example.createCriteria();
|
criteria.andEqualTo("code", userName);
|
criteria.andEqualTo("delFlag", 0);
|
CoreUser user =userMapper.selectOneByExample(example);
|
//对比密码
|
if(user==null) {
|
|
Example example1 = new Example(CityPartner.class);
|
Example.Criteria criteria1 = example1.createCriteria();
|
criteria1.andEqualTo("accountNo", userName);
|
criteria1.andEqualTo("delFlag", 0);
|
CityPartner partner =cityPartnerMapper.selectOneByExample(example1);
|
if(partner==null){
|
msg = "用户"+"不存在或者密码错误";
|
}else{
|
String salt = partner.getSalt();
|
|
if(null!=salt&&!"".equals(salt)){
|
String oldPassword = SecurityUtil.decrypt(salt,partner.getPassword());
|
if(oldPassword.equals(password)){
|
user = new CoreUser();
|
user.setName(partner.getPartnerName());
|
user.setState(partner.getState());
|
user.setPassword(partner.getPassword());
|
user.setCode(partner.getAccountNo());
|
user.setDelFlag(partner.getDelFlag());
|
user.setAttachmentId(partner.getAttachmentId());
|
user.setJobType0(partner.getJobType0());
|
user.setJobType1(partner.getJobType1());
|
user.setOrgId(Long.parseLong(partner.getOrgId()+""));
|
user.setId(Long.parseLong(partner.getId()+""));
|
List<PartnerGaode> gaodeList = gaodeService.queryPartnerGaodeList(partner.getId()+"");
|
List<String> townIds = new ArrayList<>();
|
for (PartnerGaode gaode:gaodeList) {
|
townIds.add(gaode.getTownId());
|
}
|
List<AddressLevelInfo> addressLevelInfoList=addressLevelService.queryAddressList(townIds);
|
List<Map<String,String>> children = new ArrayList<>();
|
Map<String,Object> map1 = new HashMap<>();
|
String cityName = "";
|
int i=1;
|
for (AddressLevelInfo address:addressLevelInfoList) {
|
Map<String,String> townMap = new HashMap<>();
|
if(cityName.equals(address.getLevel2Name())){
|
townMap.put("name",address.getLevel3Name());
|
townMap.put("id",address.getLevel3Id());
|
children.add(townMap);
|
}else{
|
map1 = new HashMap<>();
|
if(null!=cityName&&!"".equals(cityName)){
|
map1.put("children",children);
|
cityTown.add(map1);
|
}else{
|
map1.put("cityName",address.getLevel2Name());
|
map1.put("cityId",address.getLevel2Id());
|
cityName = address.getLevel2Name();
|
children = new ArrayList<>();
|
townMap.put("name",address.getLevel3Name());
|
townMap.put("id",address.getLevel3Id());
|
children.add(townMap);
|
}
|
|
}
|
if(addressLevelInfoList.size()==i){
|
map1.put("children",children);
|
cityTown.add(map1);
|
}
|
i++;
|
}
|
userType="2";
|
}else{
|
msg = "用户"+"不存在或者密码错误";
|
}
|
}else{
|
msg = "用户"+"不存在或者密码错误";
|
}
|
|
}
|
|
}else{
|
if(!user.getState().equals(GeneralStateEnum.ENABLE.getValue())){
|
msg ="用户"+"已经失效";
|
}
|
if(user.getDelFlag()==DelFlagEnum.DELETED.getValue()) {
|
msg ="用户"+"已经删除";
|
}
|
String salt = user.getSalt();
|
|
if(null!=salt&&!"".equals(salt)) {
|
String oldPassword = SecurityUtil.decrypt(salt, user.getPassword());
|
if (oldPassword.equals(password)) {
|
}else{
|
msg = "用户"+"不存在或者密码错误";
|
}
|
}else{
|
if (user.getPassword().equals(password)) {
|
}else{
|
msg = "用户"+"不存在或者密码错误";
|
}
|
}
|
}
|
UserLoginInfoAdmin loginInfo = new UserLoginInfoAdmin();
|
|
if(!"".equals(msg)){
|
map.put("msg",msg);
|
map.put("userLoginInfo",loginInfo);
|
}else{
|
List<CoreOrg> orgs = new ArrayList<>();
|
if(null!=user.getOrgId()){
|
orgs = getUserOrg(user.getId(),user.getOrgId());
|
}else{
|
orgs = getUserOrg(user.getId(),1);
|
}
|
loginInfo.setOrgs(orgs);
|
loginInfo.setUser(user);
|
map.put("userLoginInfo",loginInfo);
|
map.put("userType",userType);
|
map.put("cityTown",cityTown);
|
}
|
|
return map;
|
|
}
|
|
public List<CoreOrg> getUserOrg(long userId,long orgId){
|
List<CoreOrg> orgs = orgMapper.queryOrgByUser(userId);
|
if(orgs.isEmpty()){
|
//没有赋值任何角色，默认给一个所在部门
|
//排除打包站
|
if(orgId==16){
|
throw new MiException(ExceptionEnum.MONITOR_EXCEPTION);
|
}
|
CoreOrg userOrg = orgMapper.selectByPrimaryKey(orgId);
|
orgs.add(userOrg);
|
}
|
return orgs;
|
}
|
|
|
|
public void update(CoreUser user){
|
userMapper.updateByPrimaryKeySelective(user);
|
}
|
|
|
public CoreUser getUserById(Long userId){
|
return userMapper.selectOneByExample(userId);
|
}
|
|
public CoreUser getCoreUserById(Long id){
|
return userMapper.selectByPrimaryKey(id);
|
}
|
|
|
public void update(CoreUserModel model) {
|
|
Long roleId = model.getRoleId();
|
CoreRole byId = coreRoleService.findById(roleId);
|
String code = byId.getCode();
|
|
String salt = null;
|
String newPassword = null;
|
if (null != model.getPassword() && !"".equals(model.getPassword())) {
|
salt = RandomUtil.randomString(16);
|
newPassword = SecurityUtil.encrypt(salt, model.getPassword());
|
}
|
|
//合伙人
|
if (Constants.PARTNER_CODE_QG.equals(code) || Constants.PARTNER_CODE_CS.equals(code)) {
|
CityPartner user = BeanUtils.copy(model, CityPartner.class);
|
user.setPassword(newPassword);
|
user.setSalt(salt);
|
cityPartnerService.updateById(user);
|
|
} else {
|
//用户
|
CoreUser user = BeanUtils.copy(model, CoreUser.class);
|
user.setPassword(newPassword);
|
user.setSalt(salt);
|
update(user);
|
}
|
coreUserRoleService.updateRoleByUserAndOrg(model.getId(), model.getOrgId(), model.getRoleId());
|
}
|
}
|
