dev:app端扫码入职流程代码修改
parent
9b6dc266d8
commit
0860cba729
|
|
@ -61,7 +61,7 @@ public class UserAddExe {
|
||||||
private final UserCorpRepository userCorpRepository;
|
private final UserCorpRepository userCorpRepository;
|
||||||
private final UserChangeRecordGateway userChangeRecordGateway;
|
private final UserChangeRecordGateway userChangeRecordGateway;
|
||||||
private final UserCorpRecordGateway userCorpRecordGateway;
|
private final UserCorpRecordGateway userCorpRecordGateway;
|
||||||
// private ZcloudRedisUtil zcloudRedisUtil;
|
private ZcloudRedisUtil zcloudRedisUtil;
|
||||||
|
|
||||||
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
@Transactional(rollbackFor = Exception.class)
|
||||||
|
|
@ -205,28 +205,27 @@ public class UserAddExe {
|
||||||
public boolean executeSendPhoneCode(UserVerifyPhoneCmd cmd) {
|
public boolean executeSendPhoneCode(UserVerifyPhoneCmd cmd) {
|
||||||
// 生成6位验证码
|
// 生成6位验证码
|
||||||
String phoneCode = RandomUtil.randomNumbers(6);
|
String phoneCode = RandomUtil.randomNumbers(6);
|
||||||
// Object phoneCodeCountObj = zcloudRedisUtil.get(RedisConstant.PHONE_CODE_COUNT + DateUtil.getDays() + ":" + cmd.getPhone());
|
Object phoneCodeCountObj = zcloudRedisUtil.get(RedisConstant.PHONE_CODE_COUNT + DateUtil.getDays() + ":" + cmd.getPhone());
|
||||||
// if(phoneCodeCountObj != null){
|
if(phoneCodeCountObj != null){
|
||||||
// Integer phoneCodeCount = (Integer) phoneCodeCountObj;
|
Integer phoneCodeCount = (Integer) phoneCodeCountObj;
|
||||||
// if(phoneCodeCount >= 20){
|
if(phoneCodeCount >= 20){
|
||||||
// throw new BizException("今天验证码已发送次数已超过20次");
|
throw new BizException("今天验证码已发送次数已超过20次");
|
||||||
// }
|
}
|
||||||
// }
|
}
|
||||||
|
|
||||||
// boolean sendFlag = sendMessage(cmd.getPhone(), phoneCode);
|
boolean sendFlag = sendMessage(cmd.getPhone(), phoneCode);
|
||||||
// if(sendFlag){
|
if(sendFlag){
|
||||||
// // 发送成功
|
// 发送成功
|
||||||
// // 放入到redis里
|
// 放入到redis里
|
||||||
// zcloudRedisUtil.set(RedisConstant.PHONE_CODE_KEY + cmd.getPhone(), phoneCode, 60 * 15);
|
zcloudRedisUtil.set(RedisConstant.PHONE_CODE_KEY + cmd.getPhone(), phoneCode, 60 * 15);
|
||||||
// // 设置新的验证码发送次数
|
// 设置新的验证码发送次数
|
||||||
// zcloudRedisUtil.set(RedisConstant.PHONE_CODE_COUNT + DateUtil.getDays() + ":" + cmd.getPhone(),
|
zcloudRedisUtil.set(RedisConstant.PHONE_CODE_COUNT + DateUtil.getDays() + ":" + cmd.getPhone(),
|
||||||
// phoneCodeCountObj == null ? 1 : (Integer)phoneCodeCountObj + 1,
|
phoneCodeCountObj == null ? 1 : (Integer)phoneCodeCountObj + 1,
|
||||||
// 60 * 60 * 24);
|
60 * 60 * 24);
|
||||||
// return true;
|
return true;
|
||||||
// }
|
}
|
||||||
|
|
||||||
// return false;
|
return false;
|
||||||
return true;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// 组装发送短信
|
// 组装发送短信
|
||||||
|
|
|
||||||
|
|
@ -130,7 +130,8 @@ public class UserUpdateExe {
|
||||||
@Transactional(rollbackFor = Exception.class)
|
@Transactional(rollbackFor = Exception.class)
|
||||||
public boolean execute(AppUserRegisterCmd cmd) {
|
public boolean execute(AppUserRegisterCmd cmd) {
|
||||||
|
|
||||||
|
// 根据手机号查询用户信息
|
||||||
|
UserDO userDO = userRepository.getByPhone(cmd.getPhone());
|
||||||
|
|
||||||
UserE userE = new UserE();
|
UserE userE = new UserE();
|
||||||
userE.checkPassword(cmd.getNewPassword(), cmd.getConfirmPassword());
|
userE.checkPassword(cmd.getNewPassword(), cmd.getConfirmPassword());
|
||||||
|
|
@ -143,6 +144,7 @@ public class UserUpdateExe {
|
||||||
// zcloudRedisUtil.del(RedisConstant.PHONE_CODE_KEY + cmd.getPhone());
|
// zcloudRedisUtil.del(RedisConstant.PHONE_CODE_KEY + cmd.getPhone());
|
||||||
|
|
||||||
BeanUtils.copyProperties(cmd, userE);
|
BeanUtils.copyProperties(cmd, userE);
|
||||||
|
userE.setId(userDO.getId());
|
||||||
userE.encryptionPassword();
|
userE.encryptionPassword();
|
||||||
userGateway.updatePassword(userE);
|
userGateway.updatePassword(userE);
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -75,5 +75,7 @@ public interface UserRepository extends BaseRepository<UserDO> {
|
||||||
PageResponse<UserDO> listXgf(Map<String, Object> params);
|
PageResponse<UserDO> listXgf(Map<String, Object> params);
|
||||||
|
|
||||||
void sendResignationMq(Long userId, Long corpinfoId);
|
void sendResignationMq(Long userId, Long corpinfoId);
|
||||||
|
|
||||||
|
UserDO getByPhone(String phone);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -426,5 +426,12 @@ public class UserRepositoryImpl extends BaseRepositoryImpl<UserMapper, UserDO> i
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public UserDO getByPhone(String phone) {
|
||||||
|
QueryWrapper<UserDO> queryWrapper = new QueryWrapper<>();
|
||||||
|
queryWrapper.eq("phone", phone);
|
||||||
|
return getOne(queryWrapper);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue