bug修改-修改密码
This commit is contained in:
parent
a268b9c747
commit
2abfb5c70a
@ -194,4 +194,7 @@ public class SystemUser implements Serializable {
|
||||
@TableField(exist = false)
|
||||
@ApiModelProperty(value = "邮箱")
|
||||
private java.lang.String personMail;
|
||||
@TableField(exist = false)
|
||||
@ApiModelProperty(value = "默认1,通过邮箱验证,0则不通过邮箱验证")
|
||||
private java.lang.Integer isCheckCode;
|
||||
}
|
||||
|
||||
@ -31,8 +31,6 @@ public interface ISystemUserService extends IService<SystemUser> {
|
||||
/**
|
||||
* 根据企业或项目SN查找账号列表
|
||||
*
|
||||
* @param sn
|
||||
* @param type 3 项目级别账号
|
||||
* @return
|
||||
*/
|
||||
List<SystemUser> getSystemUsersBySn(Map<String, Object> map);
|
||||
|
||||
@ -76,6 +76,18 @@ import java.util.stream.Collectors;
|
||||
@Slf4j
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
public class SystemUserServiceImpl extends ServiceImpl<SystemUserMapper, SystemUser> implements ISystemUserService {
|
||||
/**
|
||||
* 重置密码的邮箱验证码
|
||||
*/
|
||||
public static final String UPDATE_PW_EMAIL_CODE = "UPDATE_PW_EMAIL_CODE:";
|
||||
/**
|
||||
* 修改密码的有效期
|
||||
*/
|
||||
public static final String UPDATE_PW_UUID = "UPDATE_PW_UUID:";
|
||||
/**
|
||||
* redis密码登录失败次数前缀
|
||||
*/
|
||||
private static final String PW_FAILED_COUNT_PREFIX = "USER_PW_FAILED_COUNT:";
|
||||
@Autowired
|
||||
private MechanicalEquipmentPositionDevMapper mechanicalEquipmentPositionDevMapper;
|
||||
@Autowired
|
||||
@ -128,20 +140,8 @@ public class SystemUserServiceImpl extends ServiceImpl<SystemUserMapper, SystemU
|
||||
private EmailUtils emailUtils;
|
||||
@Autowired
|
||||
private XzSystemUserToCompanyProjectMapper xzSystemUserToCompanyProjectMapper;
|
||||
/**
|
||||
* 重置密码的邮箱验证码
|
||||
*/
|
||||
public static final String UPDATE_PW_EMAIL_CODE = "UPDATE_PW_EMAIL_CODE:";
|
||||
/**
|
||||
* 修改密码的有效期
|
||||
*/
|
||||
public static final String UPDATE_PW_UUID = "UPDATE_PW_UUID:";
|
||||
@Value("${mqtt-scope}")
|
||||
private String scope;
|
||||
/**
|
||||
* redis密码登录失败次数前缀
|
||||
*/
|
||||
private static final String PW_FAILED_COUNT_PREFIX = "USER_PW_FAILED_COUNT:";
|
||||
|
||||
@Override
|
||||
public Map<String, Object> getToken(Map<String, Object> map) {
|
||||
@ -341,8 +341,12 @@ public class SystemUserServiceImpl extends ServiceImpl<SystemUserMapper, SystemU
|
||||
companyConfig.setDiffDay((int) DateUtil.between(currentDate, DateUtil.offset(expireTime, DateField.DAY_OF_MONTH, 1), DateUnit.DAY));
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
if (systemUser.getAccountType() == 6) {
|
||||
List<SystemUser> users = getProjectChilderSystemUserList(new MapBuilder<String, Object>().put("projectSn", systemUser.getSn()).build());
|
||||
if (CollUtil.isNotEmpty(users)) {
|
||||
systemUser.setPersonMail(users.get(0).getPersonMail());
|
||||
}
|
||||
}
|
||||
if (companyConfig == null || companyConfig.getIsEnable() == 0) {
|
||||
throw new OpenAlertException(MessageUtil.get("loginEnabledErr"));
|
||||
}
|
||||
@ -1223,7 +1227,6 @@ public class SystemUserServiceImpl extends ServiceImpl<SystemUserMapper, SystemU
|
||||
}
|
||||
|
||||
|
||||
|
||||
@Override
|
||||
public List<SystemUser> getSystemUserList(Map<String, Object> map) {
|
||||
companyService.getCompanyType(map);
|
||||
@ -1289,7 +1292,10 @@ public class SystemUserServiceImpl extends ServiceImpl<SystemUserMapper, SystemU
|
||||
|
||||
@Override
|
||||
public void xzUpdatePw(SystemUser systemUser) {
|
||||
checkCode(systemUser);
|
||||
Integer isCheckCode = systemUser.getIsCheckCode();
|
||||
if (isCheckCode == null || isCheckCode == 1) {
|
||||
checkCode(systemUser);
|
||||
}
|
||||
SystemUser su = systemUserMapper.selectById(systemUser.getUserId());
|
||||
if (su == null) {
|
||||
throw new OpenAlertException("userId不存在");
|
||||
|
||||
@ -33,7 +33,7 @@ import com.zhgd.xmgl.modules.worker.mapper.WorkerAttendanceMapper;
|
||||
import com.zhgd.xmgl.modules.worker.mapper.WorkerInfoMapper;
|
||||
import com.zhgd.xmgl.modules.worker.service.impl.WorkerInfoServiceImpl;
|
||||
import com.zhgd.xmgl.util.DateUtils;
|
||||
import com.zhgd.xmgl.util.MapParamBuilder;
|
||||
import com.zhgd.xmgl.util.MapBuilder;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.commons.collections.MapUtils;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
@ -258,7 +258,7 @@ public class CarPassRecordServiceImpl extends ServiceImpl<CarPassRecordMapper, C
|
||||
public void saveDriverPassData(CarPassRecord carPassRecord, CarInfo carInfo) {
|
||||
List<WorkerInfo> list;
|
||||
if (Objects.equals(carInfo.getCarModuleType(), 3)) {
|
||||
WorkerInfo workerInfo = workerInfoService.selectWorkerInfoByIdCard(new MapParamBuilder<String, Object>().put("idCard", carInfo.getOutsideDriverIdCard()).put("projectSn", carInfo.getProjectSn()).build());
|
||||
WorkerInfo workerInfo = workerInfoService.selectWorkerInfoByIdCard(new MapBuilder<String, Object>().put("idCard", carInfo.getOutsideDriverIdCard()).put("projectSn", carInfo.getProjectSn()).build());
|
||||
if (workerInfo == null) {
|
||||
return;
|
||||
}
|
||||
|
||||
@ -598,7 +598,7 @@ public class AiAnalyseHardWareAlarmRecordServiceImpl extends ServiceImpl<AiAnaly
|
||||
for (String noticeUserId : noticeUserIds) {
|
||||
noticeService.addUserNotice(Long.valueOf(noticeUserId), "您有一条AI预警数据需要处置,请及时查看。", "AI预警通知", "8");
|
||||
}
|
||||
List<SystemUser> users = systemUserService.getSystemUsers(new MapParamBuilder<String, Object>().put("type", 3).put("sn", record.getProjectSn()).build());
|
||||
List<SystemUser> users = systemUserService.getSystemUsers(new MapBuilder<String, Object>().put("type", 3).put("sn", record.getProjectSn()).build());
|
||||
for (SystemUser systemUser : users) {
|
||||
noticeService.addUserNotice(systemUser.getUserId(), "有一条AI预警数据已处置推送", "AI预警通知", "8");
|
||||
}
|
||||
|
||||
@ -169,7 +169,7 @@ public class XzRegistryController {
|
||||
return Result.ok();
|
||||
}
|
||||
|
||||
@ApiOperation(value = "根据账号查询注册邮箱", notes = "根据账号查询注册邮箱", httpMethod = "POST")
|
||||
@ApiOperation(value = "根据账号查询注册邮箱(或者查询项目子账号的邮箱)", notes = "根据账号查询注册邮箱(或者查询项目子账号的邮箱)", httpMethod = "POST")
|
||||
@PostMapping(value = "/getRegistryEmail")
|
||||
public Result<HashMap<String, Object>> getRegistryEmail(@RequestBody SystemUser systemUser) {
|
||||
return Result.success(xzRegistryService.getRegistryEmail(systemUser));
|
||||
|
||||
@ -22,6 +22,7 @@ import com.zhgd.xmgl.modules.xz.entity.XzRegistry;
|
||||
import com.zhgd.xmgl.modules.xz.mapper.XzRegistryMapper;
|
||||
import com.zhgd.xmgl.modules.xz.service.IXzRegistryService;
|
||||
import com.zhgd.xmgl.util.EmailUtils;
|
||||
import com.zhgd.xmgl.util.MapBuilder;
|
||||
import com.zhgd.xmgl.util.PageUtil;
|
||||
import com.zhgd.xmgl.util.RefUtil;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
@ -44,12 +45,6 @@ import java.util.Objects;
|
||||
@Service
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
public class XzRegistryServiceImpl extends ServiceImpl<XzRegistryMapper, XzRegistry> implements IXzRegistryService {
|
||||
@Autowired
|
||||
private RedisDistributedLock redisDistributedLock;
|
||||
@Autowired
|
||||
private XzRegistryMapper xzRegistryMapper;
|
||||
@Autowired
|
||||
private SystemLogoConfigMapper systemLogoConfigMapper;
|
||||
@Autowired
|
||||
SystemUserMapper systemUserMapper;
|
||||
@Autowired
|
||||
@ -58,10 +53,14 @@ public class XzRegistryServiceImpl extends ServiceImpl<XzRegistryMapper, XzRegis
|
||||
ICompanyService companyService;
|
||||
@Autowired
|
||||
EmailUtils emailUtils;
|
||||
|
||||
@Autowired
|
||||
CompanyMapper companyMapper;
|
||||
|
||||
@Autowired
|
||||
private RedisDistributedLock redisDistributedLock;
|
||||
@Autowired
|
||||
private XzRegistryMapper xzRegistryMapper;
|
||||
@Autowired
|
||||
private SystemLogoConfigMapper systemLogoConfigMapper;
|
||||
|
||||
@Override
|
||||
public IPage<XzRegistry> queryPageList(HashMap<String, Object> paramMap) {
|
||||
@ -218,16 +217,31 @@ public class XzRegistryServiceImpl extends ServiceImpl<XzRegistryMapper, XzRegis
|
||||
|
||||
@Override
|
||||
public HashMap<String, Object> getRegistryEmail(SystemUser systemUser) {
|
||||
XzRegistry xzRegistry = xzRegistryMapper.selectOne(new LambdaQueryWrapper<XzRegistry>()
|
||||
.eq(XzRegistry::getAccount, systemUser.getAccount())
|
||||
.eq(XzRegistry::getApprovalProcess, 2)
|
||||
.last("order by create_time desc limit 1")
|
||||
);
|
||||
if (xzRegistry == null) {
|
||||
throw new OpenAlertException("账号未注册成功");
|
||||
SystemUser su = systemUserMapper.selectOne(new LambdaQueryWrapper<SystemUser>()
|
||||
.eq(SystemUser::getAccount, systemUser.getAccount()));
|
||||
if (su == null) {
|
||||
throw new OpenAlertException("账号不存在");
|
||||
}
|
||||
String email = "";
|
||||
if (su.getAccountType() == 10 || su.getAccountType() == 11) {
|
||||
XzRegistry xzRegistry = xzRegistryMapper.selectOne(new LambdaQueryWrapper<XzRegistry>()
|
||||
.eq(XzRegistry::getAccount, systemUser.getAccount())
|
||||
.eq(XzRegistry::getApprovalProcess, 2)
|
||||
.last("order by create_time desc limit 1")
|
||||
);
|
||||
if (xzRegistry == null) {
|
||||
throw new OpenAlertException("账号未注册成功");
|
||||
}
|
||||
email = xzRegistry.getEmail();
|
||||
} else if (su.getAccountType() == 6) {
|
||||
List<SystemUser> users = systemUserService.getProjectChilderSystemUserList(new MapBuilder<String, Object>().put("projectSn", su.getSn()).build());
|
||||
if (CollUtil.isEmpty(users)) {
|
||||
throw new OpenAlertException("项目子账号不存在");
|
||||
}
|
||||
email = users.get(0).getPersonMail();
|
||||
}
|
||||
HashMap<String, Object> map = new HashMap<>();
|
||||
map.put("email", xzRegistry.getEmail());
|
||||
map.put("email", email);
|
||||
return map;
|
||||
}
|
||||
|
||||
|
||||
15
src/main/java/com/zhgd/xmgl/util/HttpServletRequestUtil.java
Normal file
15
src/main/java/com/zhgd/xmgl/util/HttpServletRequestUtil.java
Normal file
@ -0,0 +1,15 @@
|
||||
package com.zhgd.xmgl.util;
|
||||
|
||||
import com.zhgd.jeecg.common.util.SpringContextUtils;
|
||||
|
||||
import javax.servlet.http.HttpServletRequest;
|
||||
|
||||
public class HttpServletRequestUtil {
|
||||
public static String getParameter(String name) {
|
||||
HttpServletRequest request = SpringContextUtils.getHttpServletRequest();
|
||||
if (request == null) {
|
||||
return null;
|
||||
}
|
||||
return request.getParameter(name);
|
||||
}
|
||||
}
|
||||
@ -10,14 +10,14 @@ import java.util.Map;
|
||||
* @param <V>
|
||||
* @author Zhegui
|
||||
*/
|
||||
public class MapParamBuilder<K, V> {
|
||||
public class MapBuilder<K, V> {
|
||||
|
||||
private Map<K, V> mapParam;
|
||||
|
||||
/**
|
||||
* 默认构造函数
|
||||
*/
|
||||
public MapParamBuilder() {
|
||||
public MapBuilder() {
|
||||
mapParam = new HashMap<K, V>();
|
||||
}
|
||||
|
||||
@ -26,7 +26,7 @@ public class MapParamBuilder<K, V> {
|
||||
*
|
||||
* @param mapParam
|
||||
*/
|
||||
public MapParamBuilder(Map<K, V> mapParam) {
|
||||
public MapBuilder(Map<K, V> mapParam) {
|
||||
this.mapParam = mapParam;
|
||||
}
|
||||
|
||||
@ -37,7 +37,7 @@ public class MapParamBuilder<K, V> {
|
||||
* @param value
|
||||
* @return
|
||||
*/
|
||||
public MapParamBuilder<K, V> put(K key, V value) {
|
||||
public MapBuilder<K, V> put(K key, V value) {
|
||||
mapParam.put(key, value);
|
||||
return this;
|
||||
}
|
||||
@ -48,7 +48,7 @@ public class MapParamBuilder<K, V> {
|
||||
* @param key
|
||||
* @return
|
||||
*/
|
||||
public MapParamBuilder<K, V> remove(K key) {
|
||||
public MapBuilder<K, V> remove(K key) {
|
||||
mapParam.remove(key);
|
||||
return this;
|
||||
}
|
||||
@ -63,7 +63,7 @@ public class MapParamBuilder<K, V> {
|
||||
}
|
||||
|
||||
public static void main(String[] args) {
|
||||
Map<String, String> map = new MapParamBuilder<String, String>()
|
||||
Map<String, String> map = new MapBuilder<String, String>()
|
||||
.put("key1", "value1")
|
||||
.put("key2", "value2")
|
||||
.build();
|
||||
@ -80,7 +80,7 @@ public class MapParamBuilder<K, V> {
|
||||
boolean flag = true;
|
||||
if (flag) {
|
||||
System.out.println("发现缺少参数,或者需要补充参数");
|
||||
map = new MapParamBuilder<String, String>(map)
|
||||
map = new MapBuilder<String, String>(map)
|
||||
.put("key3", "value3")
|
||||
.put("key4", "value4")
|
||||
.put("key5", "value5")
|
||||
Loading…
x
Reference in New Issue
Block a user