package com.product.admin.service;
|
|
import com.product.admin.config.CmnConst;
|
import com.product.admin.config.SystemCode;
|
import com.product.admin.service.idel.IPersonalCenterService;
|
import com.product.common.lang.StringUtils;
|
import com.product.email.service.SendEmailService;
|
import com.product.core.cache.DataPoolCacheImpl;
|
import com.product.core.config.Global;
|
import com.product.core.dao.BaseDao;
|
import com.product.core.entity.DataTableEntity;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.core.exception.BaseException;
|
import com.product.core.service.support.AbstractBaseService;
|
import com.product.core.spring.context.SpringMVCContextHolder;
|
import com.product.core.transfer.Transactional;
|
import com.product.module.sys.entity.SystemUser;
|
import com.product.module.sys.service.UserService;
|
import com.product.util.BaseUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Component;
|
|
import java.net.URLDecoder;
|
import java.net.URLEncoder;
|
import java.util.Date;
|
import java.util.List;
|
|
|
/**
|
* Copyright LX-BASE
|
*
|
* @Title: PersonalCenterService
|
* @Project: LX-BASE-SERVER
|
* @Date: 2020-05-30 17:28
|
* @Author: ZhouJie
|
* @Description: 个人中心
|
*/
|
@Component
|
public class PersonalCenterService extends AbstractBaseService implements IPersonalCenterService {
|
|
@Autowired
|
public BaseDao baseDao;
|
|
@Autowired
|
UserService userService;
|
@Autowired
|
SendEmailService sendEmailService;
|
|
@Autowired
|
UpdateLoginUserInfoService updateLoginUserInfoService;
|
|
/**
|
* 个人中心修改用户头像
|
*
|
* @param fse
|
* @return
|
* @throws BaseException
|
*/
|
public Boolean updateUserAvatar(FieldSetEntity fse) throws BaseException {
|
FieldSetEntity fs = new FieldSetEntity();
|
fs.setTableName(CmnConst.PRODUCT_SYS_USERS);
|
fs.setValue(CmnConst.UUID, fse.getUUID());
|
fs.setValue(CmnConst.THUMBNAIL_IMG, fse.getString(CmnConst.THUMBNAIL_IMG));
|
baseDao.saveFieldSetEntity(fs);
|
updateLoginUserInfoService.updateUserInfoByUserId(SpringMVCContextHolder.getCurrentUser().getUser_id() + "", 1, false);
|
return true;
|
}
|
|
/**
|
* 个人中心修改用户信息
|
*
|
* @param fse
|
* @return
|
* @throws BaseException
|
*/
|
@Transactional
|
@Override
|
public Boolean updatePersonalInfo(FieldSetEntity fse) throws BaseException {
|
SystemUser currentUser = SpringMVCContextHolder.getCurrentUser();
|
FieldSetEntity fs = new FieldSetEntity();
|
fs.setTableName(CmnConst.PRODUCT_SYS_USERS);
|
fs.setValue(CmnConst.USER_NAME, fse.getString(CmnConst.USER_NAME));
|
fs.setValue(CmnConst.UUID, currentUser.getUuid());
|
fs.setValue(CmnConst.USER_PHONE_NUMBER, fse.getString(CmnConst.USER_PHONE_NUMBER));
|
fs.setValue(CmnConst.GENDER, fse.getString("sex"));
|
fs.setValue(CmnConst.USER_PRIMARY_EMAIL, fse.getString(CmnConst.USER_PRIMARY_EMAIL));
|
baseDao.saveFieldSetEntity(fs);
|
baseDao.executeUpdate("UPDATE product_sys_staffs SET sex=?,show_name=?,staff_email=? WHERE user_id=?",
|
new Object[]{fse.getString("sex"),
|
fse.getString(CmnConst.USER_NAME),
|
fse.getString(CmnConst.USER_PRIMARY_EMAIL), currentUser.getUser_id()});
|
updateLoginUserInfoService.updateUserInfoByUserId(currentUser.getUser_id() + "", 1, false);
|
return true;
|
}
|
|
public FieldSetEntity personalCenterInfo() throws BaseException {
|
StringBuilder sql = new StringBuilder();
|
SystemUser currentUser = SpringMVCContextHolder.getCurrentUser();
|
if (!currentUser.isManager()) {
|
sql.append("\n SELECT b.gender, b.user_phone_number,b.user_primary_email,b.user_name,a.sex,b.user_id,b.user_signature,b.thumbnail_img,c.job_post_name,d.org_level_name dept_name,d.uuid dept_uuid,d.org_level_uuid,d.org_level_all ,e.org_level_name company_name FROM product_sys_staffs a ");
|
sql.append("\n join product_sys_users b on a.user_id=b.user_id and a.user_id=? ");
|
sql.append("\n join product_sys_job_posts c on a.job_post_uuid=c.uuid ");
|
sql.append("\n join product_sys_org_levels d on d.uuid=a.dept_uuid ");
|
sql.append("\n join product_sys_org_levels e on e.uuid=a.org_level_uuid ");
|
} else {
|
sql.append(" SELECT ");
|
sql.append(" thumbnail_img,a.uuid,b.uuid uuid1,thumbnail_img,user_account,user_name, ");
|
sql.append(" user_phone_number, ");
|
sql.append(" user_primary_email, ");
|
sql.append(" org_level_uuid, ");
|
sql.append(" role_uuids, ");
|
sql.append(" a.created_utc_datetime, ");
|
sql.append(" gender ");
|
sql.append(" FROM ");
|
sql.append(" product_sys_users a ");
|
sql.append(" JOIN product_sys_org_manager b ON a.user_id = b.user_id ");
|
sql.append(" WHERE ");
|
sql.append(" a.user_id =? ");
|
}
|
FieldSetEntity fs = getBaseDao().getFieldSetEntityBySQL(sql.toString(), new Object[]{SpringMVCContextHolder.getCurrentUserId()}, false);
|
DataTableEntity dt = new DataTableEntity();
|
dt.addFieldSetEntity(fs);
|
baseDao.loadPromptData(dt);
|
if (currentUser.isManager()) {
|
String role_uuds = fs.getString("role_uuids");
|
if (!StringUtils.isEmpty(role_uuds)) {
|
sql = new StringBuilder();
|
sql.append(" select group_concat(role_name) role_name FROM product_sys_role where ");
|
sql.append(BaseUtil.buildQuestionMarkFilter("uuid", role_uuds.split(",").length, true));
|
FieldSetEntity role = baseDao.getFieldSetEntityBySQL(sql.toString(), role_uuds.split(","), false);
|
if (role != null) {
|
fs.setValue("role_uuids", role.getString("role_name"));
|
}
|
}
|
}
|
return fs;
|
}
|
|
/**
|
* @throws BaseException
|
* @Date: 2020-05-30 14:04
|
* @Author: ZhouJie
|
* @Description: 根据用户uuid 查询用户信息
|
*/
|
public FieldSetEntity findUserInfoByUserUuid(String uuid) throws BaseException {
|
return baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_USERS, uuid, true);
|
}
|
|
/**
|
* @throws Exception
|
* @Date: 2020-05-30 14:04
|
* @Author: ZhouJie
|
* @Description: 发送修改密码邮件
|
*/
|
@Async
|
public boolean sendPasswordResetEmail(FieldSetEntity fs) {
|
String sendPwdRsetEmail = "sendPasswordResetEmail";
|
String uAccount = fs.getString(CmnConst.USER_ACCOUNT);
|
String login_url = fs.getString("login_url");
|
//登录URL地址在修改成功后，跳转到该地址，如果是App端没有，则为空，前端判断没有，则提标手动进入登录界面
|
if (login_url == null) {
|
login_url = "";
|
}
|
//周杰 2020年12月17日 上午11:16
|
if (StringUtils.isEmpty(uAccount)) {
|
throw new BaseException(SystemCode.SYSTEM_GET_USERNAME_FAIL.getValue(), SystemCode.SYSTEM_GET_USERNAME_FAIL.getText(), this.getClass(), sendPwdRsetEmail);
|
}
|
//2021年2月2日 用户不存在，不提示用户不存在，不发邮件操作，正常结束。
|
FieldSetEntity fsuname = baseDao.getFieldSetEntityByFilter("product_sys_users", "user_account = ?", new Object[]{uAccount}, false);
|
if (fsuname == null) {
|
return true;
|
}
|
String token = userService.createTokenInforMail(uAccount.toString());
|
//把邮件token存入redis中
|
DataPoolCacheImpl.getInstance().setUserMailToken(fsuname.getString("user_id"), token);
|
|
FieldSetEntity fss = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_USERS, CmnConst.USER_ACCOUNT + " = ?", new Object[]{uAccount}, false);
|
if (fss == null) {
|
throw new BaseException(SystemCode.SYSTEM_GET_USERINFO_FAIL.getValue(), SystemCode.SYSTEM_GET_USERINFO_FAIL.getText(), this.getClass(), sendPwdRsetEmail);
|
}
|
String url = "http://" + fs.getString("url") + "/#/reset-password";//忘记密码跳转地址
|
//查询管理员/员工信息
|
FieldSetEntity fsm = null;
|
if ("1".equals(fss.getString(CmnConst.IS_MANAGER))) { //管理员
|
url = Global.getSystemConfig("resetpwd.lxurl", "");//获取配置的管理员登录地址
|
login_url = URLEncoder.encode(Global.getSystemConfig("resetpwd.lxlogin_url", ""));//获取配置的管理员忘记密码跳转页面地址
|
fsm = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_MANAGER, CmnConst.USER_ID + " = ?", new Object[]{fss.getString(CmnConst.USER_ID)}, false);
|
} else { //普通员工员
|
url = Global.getSystemConfig("resetpwd.lxeurl", "");//获取配置的员工登录地址
|
login_url = URLEncoder.encode(Global.getSystemConfig("resetpwd.lxelogin_url", ""));//获取配置的员工忘记密码跳转页面地址
|
fsm = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_STAFFS, CmnConst.USER_ID + " = ?", new Object[]{fss.getString(CmnConst.USER_ID)}, false);
|
}
|
if (fsm == null) {
|
throw new BaseException(SystemCode.SYSTEM_FIND_MANAGEMENT_FAIL.getValue(), SystemCode.SYSTEM_FIND_MANAGEMENT_FAIL.getText(), this.getClass(), sendPwdRsetEmail);
|
}
|
// 设置邮件内容
|
//周杰 2020年12月17日 上午11:16
|
if (!StringUtils.isEmpty(fss.getString("default_language"))) {
|
login_url = login_url + "&language=" + fss.getString("default_language");
|
} else {
|
//查询公司信息(多个公司默认查询第一个)
|
String oluuid = fsm.getString(CmnConst.ORG_LEVEL_UUID);
|
if (oluuid.indexOf(",") >= 0) {
|
oluuid = oluuid.substring(0, oluuid.indexOf(","));
|
}
|
FieldSetEntity fsc = baseDao.getFieldSetEntityByFilter("product_sys_company_language", CmnConst.ORG_LEVEL_UUID + " = ?", new Object[]{oluuid}, false);
|
if (fsc == null) {
|
throw new BaseException(SystemCode.SYSTEM_GET_COMPANY_FAIL.getValue(), SystemCode.SYSTEM_GET_COMPANY_FAIL.getText(), this.getClass(), sendPwdRsetEmail);
|
}
|
login_url = login_url + "&language=" + fsc.getString("language_code");
|
}
|
fs.setValue(CmnConst.USER_ID, fss.getString(CmnConst.USER_ID));
|
fs.setValue("url", url);
|
fs.setValue("token", token);
|
fs.setValue("login_url", login_url);
|
fs.setValue(CmnConst.USER_PRIMARY_EMAIL, fss.getString(CmnConst.USER_PRIMARY_EMAIL));
|
String resultInfo = sendEmailService.parseMailTemplate(CmnConst.FORGET_THE_PASSWORD, fs);
|
if (SystemCode.SYSTEM_OPERATION_SUCCESS.getText().equals(resultInfo)) {
|
return true;
|
} else {
|
throw new BaseException(SystemCode.SYSTEM_PASSWORD_EMAIL_FAIL.getValue(), SystemCode.SYSTEM_PASSWORD_EMAIL_FAIL.getText(), this.getClass(), sendPwdRsetEmail);
|
}
|
|
}
|
|
|
/**
|
* @Date: 2020-05-30 15:30
|
* @Author: ZhouJie
|
* @Description: 保存新密码（登录修改密码，验证旧密码）
|
*/
|
@Transactional
|
public boolean saveUpdatePwd(FieldSetEntity fs) throws BaseException {
|
String saveUpdatePassword = "saveUpdatePwd";
|
int uid = SpringMVCContextHolder.getCurrentUser().getUser_id();//回去当前登录用户id
|
if (uid == 0) {
|
throw new BaseException(SystemCode.SYSTEM_ACQUIRE_PARAM_FAIL.getValue(), SystemCode.SYSTEM_ACQUIRE_PARAM_FAIL.getText(), this.getClass(), saveUpdatePassword);
|
}
|
FieldSetEntity fsu = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_USERS, CmnConst.USER_ID + " = ?", new Object[]{uid}, false);
|
if (fsu == null) {
|
throw new BaseException(SystemCode.SYSTEM_GET_USERINFO_FAIL.getValue(), SystemCode.SYSTEM_GET_USERINFO_FAIL.getText(), this.getClass(), saveUpdatePassword);
|
}
|
String userName = SpringMVCContextHolder.getCurrentUser().getUser_account();//用户名
|
String oluuid = null;
|
FieldSetEntity stfs = null;
|
String isM = fsu.getString(CmnConst.IS_MANAGER);
|
if (!"1".equals(isM)) {
|
stfs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_STAFFS, CmnConst.USER_ID + " = ?", new Object[]{uid}, false);
|
if (stfs == null) {
|
throw new BaseException(SystemCode.SYSTEM_STAFF_FIND_FAIL.getValue(), SystemCode.SYSTEM_STAFF_FIND_FAIL.getText(), this.getClass(), saveUpdatePassword);
|
}
|
oluuid = stfs.getString(CmnConst.ORG_LEVEL_UUID);//用户公司
|
} else if ("1".equals(isM)) {
|
stfs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_MANAGER, CmnConst.USER_ID + " = ?", new Object[]{uid}, false);
|
if (stfs == null) {
|
throw new BaseException(SystemCode.SYSTEM_FIND_MANAGEMENT_FAIL.getValue(), SystemCode.SYSTEM_FIND_MANAGEMENT_FAIL.getText(), this.getClass(), saveUpdatePassword);
|
}
|
oluuid = stfs.getString(CmnConst.ORG_LEVEL_UUID);//管理员公司
|
if (oluuid.indexOf(",") != -1) {
|
oluuid = oluuid.substring(0, oluuid.indexOf(","));
|
}
|
}
|
if (stfs == null) {
|
throw new BaseException(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText(), this.getClass(), saveUpdatePassword);
|
}
|
//周杰 2020年12月17日 上午11:16
|
if (StringUtils.isEmpty(oluuid) || StringUtils.isEmpty(userName)) {
|
throw new BaseException(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText(), this.getClass(), saveUpdatePassword);
|
}
|
//获取的客户端信息
|
String oldPwd = fs.getString("old_pwd");//旧密码
|
oldPwd = userService.createPassWord(userName, oldPwd);//转码
|
String newPwd = fs.getString(CmnConst.USER_PWD);//新密码
|
String nowPwd = SpringMVCContextHolder.getCurrentUser().getUser_pwd();//当前密码
|
String uuid = SpringMVCContextHolder.getCurrentUser().getUuid();//获取当前登录人uuid
|
//验证原密码与当前登录人密码是否一致
|
if (oldPwd.equals(nowPwd)) {
|
//验证密码格式是否符合要求
|
if (checkNewPwd(oluuid, newPwd)) {
|
newPwd = userService.createPassWord(userName, newPwd);//新密码转码
|
//保存符合要求的新密码
|
fs.setValue("uuid", uuid);
|
fs.setValue(CmnConst.USER_PWD, newPwd);
|
//先验证是否允许重复使用密码，再保存到历史记录中
|
if (saveHistoryPassWord(newPwd)) {
|
fs.setValue(CmnConst.USER_ACCOUNT, userName);
|
baseDao.update(fs);
|
//修改成功给用户/(及管理员)发送邮件
|
isEmailNotification(fs.getString(CmnConst.USER_ACCOUNT));
|
}
|
return true;
|
}
|
throw new BaseException(SystemCode.SYSTEM_NEW_PASSWORD_ERROR.getValue(), SystemCode.SYSTEM_NEW_PASSWORD_ERROR.getText(), this.getClass(), saveUpdatePassword);
|
}
|
throw new BaseException(SystemCode.SYSTEM_OLD_PASSWORD_ERROR.getValue(), SystemCode.SYSTEM_OLD_PASSWORD_ERROR.getText(), this.getClass(), saveUpdatePassword);
|
}
|
|
|
/**
|
* @Date: 2020-08-18 17:30
|
* @Author: ZhouJie
|
* @Description: 保存新密码（忘记密码，直接保存新密码）
|
*/
|
@Transactional
|
public boolean saveNewPwd(FieldSetEntity fs) throws BaseException {
|
String saveNewPassword = "saveNewPwd";
|
FieldSetEntity fss = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_USERS, "user_account = ? or user_primary_email = ?", new Object[]{fs.getString(CmnConst.USER_ACCOUNT), fs.getString(CmnConst.USER_ACCOUNT)}, false);
|
if (fss == null) {
|
throw new BaseException(SystemCode.SYSTEM_GET_USERINFO_FAIL.getValue(), SystemCode.SYSTEM_GET_USERINFO_FAIL.getText(), this.getClass(), saveNewPassword);
|
}
|
String uuid = fss.getString(CmnConst.UUID);
|
String uid = fss.getString(CmnConst.USER_ID);
|
//获取的客户端信息
|
String newPwd = fs.getString(CmnConst.USER_PWD);//新密码
|
String userName = fss.getString(CmnConst.USER_ACCOUNT);//用户名
|
newPwd = userService.createPassWord(userName, newPwd);
|
String isM = fss.getString(CmnConst.IS_MANAGER);
|
String oluuid = null;
|
FieldSetEntity stfs = null;
|
//员工
|
if ("0".equals(isM)) {
|
stfs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_STAFFS, CmnConst.USER_ID + " = ?", new Object[]{uid}, false);
|
oluuid = stfs.getString(CmnConst.ORG_LEVEL_UUID);//用户公司
|
}
|
//管理员
|
if ("1".equals(isM)) {
|
stfs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_MANAGER, CmnConst.USER_ID + " = ?", new Object[]{uid}, false);
|
oluuid = stfs.getString(CmnConst.ORG_LEVEL_UUID);//管理员公司
|
if (oluuid.indexOf(",") != -1) {
|
oluuid = oluuid.substring(0, oluuid.indexOf(","));
|
}
|
}
|
if (stfs == null) {
|
throw new BaseException(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText(), this.getClass(), saveNewPassword);
|
}
|
//周杰 2020年12月17日 上午11:16
|
if (StringUtils.isEmpty(oluuid) || StringUtils.isEmpty(userName)) {
|
throw new BaseException(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText(), this.getClass(), saveNewPassword);
|
}
|
if (checkNewPwd(oluuid, fs.getString("user_pwd"))) {
|
//保存符合要求的新密码
|
fs.setValue("uuid", uuid);
|
fs.setValue(CmnConst.USER_ACCOUNT, userName);
|
fs.setValue("user_pwd", newPwd);
|
//先验证是否允许重复使用密码，再保存到历史记录中
|
if (saveHistoryPassWord(newPwd)) {
|
baseDao.update(fs);
|
//清除登录失败信息
|
userService.loginSuccessProcess(SpringMVCContextHolder.getCurrentUser());
|
//修改成功给用户/(及管理员)发送邮件
|
isEmailNotification(fs.getString(CmnConst.USER_ACCOUNT));
|
}
|
//清除忘记密码时邮件中的token
|
DataPoolCacheImpl.getInstance().removeUserMailTokenById(uid + "");
|
} else {
|
throw new BaseException(SystemCode.SYSTEM_PASSWORD_UPDATE_FAIL.getValue(), SystemCode.SYSTEM_PASSWORD_UPDATE_FAIL.getText(), this.getClass(), saveNewPassword);
|
}
|
return true;
|
}
|
|
/**
|
* @Date: 2020-06-15 16:43
|
* @Author: ZhouJie
|
* @Description: 验证密码强度正则表达式
|
*/
|
public boolean checkNewPwd(String orgleveluuid, String pwd) throws BaseException {
|
//周杰 2020年12月17日 上午11:16
|
String checkNewPassword = "checkNewPwd";
|
if (StringUtils.isEmpty(pwd)) {
|
throw new BaseException(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText(), this.getClass(), checkNewPassword);
|
}
|
FieldSetEntity fs = null;
|
//周杰 2020年12月17日 上午11:16
|
// if (!StringUtils.isEmpty(orgleveluuid)) {
|
// fs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_PASSWORD_SECURITY, CmnConst.ORG_LEVEL_UUID + " = ?", new Object[]{orgleveluuid}, false);
|
// if (fs == null) {
|
// fs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_PASSWORD_SECURITY, SCUUID, false);
|
// if (fs == null) {
|
// throw new BaseException(SystemCode.SYSTEM_PASSWORD_SECURITY_SET.getValue(), SystemCode.SYSTEM_PASSWORD_SECURITY_SET.getText(), this.getClass(), checkNewPassword);
|
// }
|
// }
|
// } else {
|
// fs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_PASSWORD_SECURITY, SCUUID, false);
|
// if (fs == null) {
|
// throw new BaseException(SystemCode.SYSTEM_PASSWORD_SECURITY_SET.getValue(), SystemCode.SYSTEM_PASSWORD_SECURITY_SET.getText(), this.getClass(), checkNewPassword);
|
// }
|
// }
|
//获取当前登录人所属公司
|
DataTableEntity t = baseDao.listTable(CmnConst.PRODUCT_SYS_PASSWORD_SECURITY, CmnConst.ORG_LEVEL_UUID + " = ? or " + CmnConst.ORG_LEVEL_UUID + " is null or " + CmnConst.ORG_LEVEL_UUID + "='' ", new Object[]{orgleveluuid}, CmnConst.ORG_LEVEL_UUID + " desc ");
|
if (t != null && t.getRows() > 0) {
|
fs = t.getFieldSetEntity(0);
|
}
|
if (fs == null) {
|
fs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_PASSWORD_SECURITY, "security_uuid_01", false);
|
}
|
FieldSetEntity ff = regular(fs);
|
String cecknum = ff.getString("cecknum");
|
//判断密码强度
|
if (cecknum.equals("^")) {
|
return true;
|
}
|
if (!pwd.matches(cecknum)) {
|
throw new BaseException(SystemCode.SYSTEM_NEW_PASSWORD_ERROR.getValue(), SystemCode.SYSTEM_NEW_PASSWORD_ERROR.getText(), this.getClass(), checkNewPassword);
|
}
|
|
return true;
|
}
|
|
/**
|
* @Date: 2020-08-24 18:08
|
* @Author: ZhouJie
|
* @Description:返回密码强度正则表达式
|
*/
|
public FieldSetEntity returnPwdSecurity(Object langaugeUuid) throws BaseException {
|
String returnPasswordSecurity = "returnPwdSecurity";
|
FieldSetEntity fs = null;
|
String uAccount = SpringMVCContextHolder.getCurrentUser().getUser_account();//当前用户名
|
//周杰 2020年12月17日 上午11:16
|
if (StringUtils.isEmpty(uAccount)) {
|
throw new BaseException(SystemCode.SYSTEM_ACQUIRE_PARAM_FAIL.getValue(), SystemCode.SYSTEM_ACQUIRE_PARAM_FAIL.getText(), this.getClass(), returnPasswordSecurity);
|
}
|
FieldSetEntity ufs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_USERS, "user_account = ? or user_primary_email = ?", new Object[]{uAccount, uAccount}, false);
|
if (ufs == null) {
|
throw new BaseException(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText(), this.getClass(), returnPasswordSecurity);
|
}
|
String uid = ufs.getString(CmnConst.USER_ID);
|
//周杰 2020年12月17日 上午11:16
|
if (StringUtils.isEmpty(uid)) {
|
throw new BaseException(SystemCode.SYSTEM_ACQUIRE_PARAM_FAIL.getValue(), SystemCode.SYSTEM_ACQUIRE_PARAM_FAIL.getText(), this.getClass(), returnPasswordSecurity);
|
}
|
//获取当前登录人所属公司
|
String oluuid = SpringMVCContextHolder.getCurrentUser().getOrg_level_uuid();
|
DataTableEntity t = baseDao.listTable(CmnConst.PRODUCT_SYS_PASSWORD_SECURITY, CmnConst.ORG_LEVEL_UUID + " = ? or " + CmnConst.ORG_LEVEL_UUID + " is null or " + CmnConst.ORG_LEVEL_UUID + "='' ", new Object[]{oluuid}, CmnConst.ORG_LEVEL_UUID + " desc ");
|
if (t != null && t.getRows() > 0) {
|
fs = t.getFieldSetEntity(0);
|
}
|
if (fs == null) {
|
fs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_PASSWORD_SECURITY, "security_uuid_01", false);
|
}
|
if (fs != null) {
|
fs.setLanguage_code((String) langaugeUuid);
|
}
|
return regular(fs);
|
}
|
|
public FieldSetEntity regular(FieldSetEntity fs) throws BaseException {
|
if (fs == null) {
|
throw new BaseException(SystemCode.SYSTEM_PASSWORD_SECURITY_NOT_FIND.getValue(), SystemCode.SYSTEM_PASSWORD_SECURITY_NOT_FIND.getText());
|
}
|
FieldSetEntity ff = new FieldSetEntity();
|
String up = fs.getString("security_upper");//是否大写字母
|
String low = fs.getString("security_lower");//是否小写字母
|
String nums = fs.getString("security_number");//是否数字
|
String oth = fs.getString("security_other");//是否其他字符
|
String ipl = fs.getString("security_password");//是否需要密码长度
|
String plss = fs.getString("security_password_length");
|
int pls = 20;
|
//周杰 2020年12月17日 上午11:16
|
if (!StringUtils.isEmpty(plss)) {
|
pls = Integer.parseInt(fs.getString("security_password_length"));//密码长度
|
}
|
/*
|
String language_code = fs.getLanguage_code();
|
DataTableEntity verifyMessage = new DataTableEntity();
|
if (language_code != null) {
|
//updatetime 2021年2月6日12:52:09 xupengcheng 密码强度验证消息国际化查询
|
StringBuilder sb = new StringBuilder();
|
sb.append(" SELECT ");
|
sb.append(" language_master_final_key AS uuid, ");
|
sb.append(" language_value ");
|
sb.append(" FROM ");
|
sb.append(" product_sys_language_master a ");
|
sb.append(" JOIN product_sys_language_values b ON a.uuid = b.language_master_uuid ");
|
sb.append(" WHERE ");
|
sb.append(" language_master_final_key IN ( 'verify_ContainsNumbers', 'verify_Containscapitalletters', ");
|
sb.append(" 'verify_Includelowercaseletters', 'verify_Containspecialcharacters', 'verify_want_strlen_length' ) ");
|
sb.append(" AND language_code = ? ");
|
DataTableEntity dt = baseDao.listTable(sb.toString(), new Object[]{language_code});
|
if (dt != null) {
|
verifyMessage = dt;
|
}
|
}
|
*/
|
StringBuffer cecknum = new StringBuffer();
|
cecknum.append("^");
|
StringBuffer ceckmean = new StringBuffer();
|
if ("1".equals(up)) {
|
cecknum.append("(?=.*?[A-Z])");
|
ceckmean.append("包含大写字母");
|
}
|
if ("1".equals(low)) {
|
cecknum.append("(?=.*?[a-z])");
|
if (ceckmean.length() > 0) {
|
ceckmean.append("、");
|
}
|
ceckmean.append("包含小写字母");
|
// ceckmean += message;
|
}
|
if ("1".equals(nums)) {
|
cecknum.append("(?=.*?[0-9])");
|
if (ceckmean.length() > 0) {
|
ceckmean.append("、");
|
}
|
ceckmean.append("包含数字");
|
}
|
if ("1".equals(oth)) {
|
cecknum.append("(?=.*?[~.\\/({\\\\\\[\\\\\\]})|<>#?!@$%^&*=+-])");
|
if (ceckmean.length() > 0) {
|
ceckmean.append("、");
|
}
|
ceckmean.append("包含特殊字符");
|
}
|
if ("1".equals(ipl)) {
|
cecknum.append("(.{" + pls + ",20}$)");
|
if (ceckmean.length() > 0) {
|
ceckmean.append("、");
|
}
|
ceckmean.append("需要" + pls + "到20位有效字符");
|
}
|
if (ceckmean.length() > 0) {
|
ceckmean.append("。");
|
}
|
ff.setTableName("regular");
|
ff.setValue("cecknum", cecknum.toString());
|
ff.setValue("ceckmean", ceckmean.toString());
|
return ff;
|
|
}
|
|
/**
|
* 密码强度验证消息国际化获取
|
*
|
* @param messages
|
* @return
|
* @throws BaseException
|
*/
|
private String passwordVerifyMessage(List<FieldSetEntity> messages) throws BaseException {
|
if (messages != null && messages.size() > 0) {
|
FieldSetEntity fs = messages.get(0);
|
if (fs != null) {
|
String language_value = fs.getString("language_value");
|
if (!StringUtils.isEmpty(language_value)) {
|
return language_value;
|
}
|
}
|
}
|
return "";
|
}
|
|
/**
|
* 新密码保存到密码记录表中，同时比较是否与历史修改过的密码相同，如果公司允许相同，则保存，否则报错不允修改
|
*
|
* @param newPWD 新密码
|
* @return true：可以修改
|
* @throws BaseException 通用错误
|
*/
|
public boolean saveHistoryPassWord(String newPWD) throws BaseException {
|
FieldSetEntity fs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_PASSWORD_SECURITY, CmnConst.ORG_LEVEL_UUID + "=?", new Object[]{SpringMVCContextHolder.getCurrentUser().getOrg_level_uuid()}, false);
|
if (fs != null) {
|
int re = fs.getInteger("security_repeate_history_password");
|
if (re == 0) {
|
FieldSetEntity fp = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_PASSWORD_SECURITY_HISTORY, "history_password=? and user_id=?", new Object[]{newPWD, SpringMVCContextHolder.getCurrentUser().getUser_id()}, false);
|
if (fp != null) {
|
throw new BaseException(SystemCode.SYSTEM_UPDATE_PWD_REPEAT.getValue(), SystemCode.SYSTEM_UPDATE_PWD_REPEAT.getText());
|
}
|
}
|
}
|
FieldSetEntity fsp = new FieldSetEntity();
|
fsp.setTableName(CmnConst.PRODUCT_SYS_PASSWORD_SECURITY_HISTORY);
|
fsp.setValue("history_password", newPWD);
|
fsp.setValue(CmnConst.USER_ID, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
fsp.setValue("created_by", SpringMVCContextHolder.getCurrentUser().getUser_id());
|
fsp.setValue("created_utc_datetime", new Date());
|
return baseDao.add(fsp) != null ? true : false;
|
}
|
|
/**
|
* 密码强度设置修改（或重置）密码成功是否以邮件形式通知管理员
|
*
|
* @param userName 当前账号
|
* @return true：通知
|
* @throws BaseException 通用错误
|
*/
|
public boolean isEmailNotification(String userName) throws BaseException {
|
String isEmailNotFicat = "isEmailNotification";
|
//根据当前登陆人获取密码强度
|
FieldSetEntity fs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_PASSWORD_SECURITY, CmnConst.ORG_LEVEL_UUID + "=?", new Object[]{SpringMVCContextHolder.getCurrentUser().getOrg_level_uuid()}, false);
|
if (fs != null && "1".equals(fs.getString("security_notice_email"))) {
|
//以邮件通知管理员
|
FieldSetEntity fss = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_USERS, CmnConst.USER_ACCOUNT + " = ?", new Object[]{userName}, false);
|
fs.setValue(CmnConst.USER_ID, fss.getString(CmnConst.USER_ID));
|
fs.setValue(CmnConst.USER_ACCOUNT, fss.getString(CmnConst.USER_ACCOUNT));//用戶名
|
fs.setValue("user_primary_email", fss.getString("user_primary_email"));// 邮箱地址
|
String resultInfo = sendEmailService.parseMailTemplate(CmnConst.PASSWORD_MODIFIED_SUCCESSFULLY, fss);
|
if (!"admin".equals(fss.getString(CmnConst.USER_ACCOUNT))) {//员工 还需要给对应管理员发邮件
|
FieldSetEntity use = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_USERS, CmnConst.USER_ID + " = ?", new Object[]{fss.getString("created_by")}, false);
|
use.setValue(CmnConst.USER_ACCOUNT, fss.getString(CmnConst.USER_ACCOUNT));//用戶名
|
String resultInfo2 = sendEmailService.parseMailTemplate(CmnConst.PASSWORD_MODIFIED_SUCCESSFULLY, use);
|
if (SystemCode.SYSTEM_OPERATION_SUCCESS.getText().equals(resultInfo2)) {
|
return true;
|
} else {
|
throw new BaseException(SystemCode.SYSTEM_PASSWORD_EMAIL_FAIL.getValue(), SystemCode.SYSTEM_PASSWORD_EMAIL_FAIL.getText(), this.getClass(), isEmailNotFicat);
|
}
|
}
|
if (SystemCode.SYSTEM_OPERATION_SUCCESS.getText().equals(resultInfo)) {
|
return true;
|
} else {
|
throw new BaseException(SystemCode.SYSTEM_PASSWORD_EMAIL_FAIL.getValue(), SystemCode.SYSTEM_PASSWORD_EMAIL_FAIL.getText(), this.getClass(), isEmailNotFicat);
|
}
|
}
|
return false;
|
}
|
|
|
}
|
