package com.xzx.gc.role.service;
|
|
|
import cn.hutool.core.lang.Snowflake;
|
import cn.hutool.core.util.IdUtil;
|
import cn.hutool.core.util.RandomUtil;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.xzx.gc.common.exception.PlatformException;
|
import com.xzx.gc.common.exception.RestException;
|
import com.xzx.gc.common.utils.IdUtils;
|
import com.xzx.gc.common.utils.SecurityUtil;
|
import com.xzx.gc.entity.CityPartner;
|
import com.xzx.gc.entity.CoreUser;
|
import com.xzx.gc.entity.CoreUserRole;
|
import com.xzx.gc.role.mapper.CoreUserMapper;
|
import com.xzx.gc.role.mapper.CoreUserRoleMapper;
|
import com.xzx.gc.role.mapper.UserConsoleMapper;
|
import com.xzx.gc.role.model.CoreUserModel;
|
import com.xzx.gc.util.enums.DelFlagEnum;
|
import com.xzx.gc.util.enums.GeneralStateEnum;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 用户管理----->身份设定
|
*/
|
@Service
|
@Transactional
|
public class CuserConsoleService {
|
|
@Autowired
|
CoreUserMapper userDao;
|
@Autowired
|
CoreUserRoleMapper roleDao;
|
@Autowired
|
CityPartnerService cityPartnerService;
|
@Autowired
|
UserConsoleMapper cuserdao;
|
@Autowired
|
private IdUtils idUtils;
|
@Autowired
|
private CoreUserRoleService coreUserRoleService;
|
/**
|
* 根据条件查询
|
*
|
* @param query
|
*/
|
public PageInfo<CoreUserModel> queryByCondtion(CoreUserModel query) {
|
if(null!=query.getStartTime()&&!"".equals(query.getStartTime())){
|
query.setStartTime(query.getStartTime()+" 00:00:00");
|
}
|
if(null!=query.getEndTime()&&!"".equals(query.getEndTime())){
|
query.setEndTime(query.getEndTime()+" 23:59:59");
|
}
|
PageHelper.startPage(query.getPage(),query.getLimit());
|
List<CoreUserModel> ret = userDao.queryByCondtion(query);
|
PageInfo<CoreUserModel> pageInfo=new PageInfo(ret);
|
return pageInfo;
|
}
|
|
public void batchDelSysUser(List<Long> userIds) {
|
try {
|
userDao.batchDelUserByIds(userIds);
|
} catch (Exception e) {
|
throw new PlatformException("批量删除用户失败", e);
|
}
|
}
|
|
|
/**
|
* 插入一条用户数据
|
*
|
* @param user
|
*/
|
public void saveUser(CoreUser user,Long roleId) {
|
CoreUser query = new CoreUser();
|
query.setCode(user.getCode());
|
query.setDelFlag(0);
|
CoreUser dbUser = userDao.selectOne(query);
|
if (dbUser != null) {
|
throw new RestException("账户已存在");
|
}
|
user.setCreateTime(new Date());
|
user.setState(GeneralStateEnum.ENABLE.getValue());
|
user.setPassword(user.getPassword());
|
user.setDelFlag(DelFlagEnum.NORMAL.getValue());
|
userDao.insertUseGeneratedKeys(user);
|
if(StringUtils.isNotEmpty(user.getAttachmentId())){
|
}
|
CoreUserRole coreUserRole = new CoreUserRole();
|
coreUserRole.setCreateTime(new Date());
|
coreUserRole.setOrgId(user.getOrgId());
|
coreUserRole.setUserId(user.getId());
|
coreUserRole.setRoleId(roleId);
|
roleDao.insert(coreUserRole);
|
// 添加账号表
|
String value = "0";
|
|
String accountNo=idUtils.generate("ZH",4);
|
cuserdao.addCuserAccountRole(accountNo, "", user.getId()+"",value);
|
|
}
|
|
public int resetPassword(Long id, String password) {
|
CoreUser user = new CoreUser();
|
user.setId(id);
|
String salt = RandomUtil.randomString(16);
|
String newPassword = SecurityUtil.encrypt(salt, password);
|
user.setPassword(newPassword);
|
user.setSalt(salt);
|
user.setUpdateTime(new Date());
|
return userDao.updateByPrimaryKeySelective(user);
|
}
|
}
|
