注册 渠道不存在时

This commit is contained in:
2024-12-26 15:01:53 +08:00
parent 5f68d4f4ad
commit 2a25a4792b
2 changed files with 13 additions and 7 deletions

View File

@@ -144,7 +144,7 @@ public class AppLoginController {
@RequestMapping(value = "/registerCode", method = RequestMethod.POST) @RequestMapping(value = "/registerCode", method = RequestMethod.POST)
@ApiOperation("app或h5注册或登录") @ApiOperation("app或h5注册或登录")
@ResponseBody @ResponseBody
// @Debounce(interval = 2500, value = "phone") @Debounce(interval = 2500, value = "#phone")
public Result registerCode(@RequestParam String phone,String msg,String platform,Integer sysPhone, public Result registerCode(@RequestParam String phone,String msg,String platform,Integer sysPhone,
String password,String inviterCode,String wxId,String qdCode) { String password,String inviterCode,String wxId,String qdCode) {
return userService.registerCode(phone,msg,platform,sysPhone,password,inviterCode,wxId,qdCode); return userService.registerCode(phone,msg,platform,sysPhone,password,inviterCode,wxId,qdCode);

View File

@@ -50,6 +50,8 @@ import com.sqx.modules.file.utils.Md5Utils;
import com.sqx.modules.invite.service.InviteService; import com.sqx.modules.invite.service.InviteService;
import com.sqx.modules.message.entity.MessageInfo; import com.sqx.modules.message.entity.MessageInfo;
import com.sqx.modules.message.service.MessageService; import com.sqx.modules.message.service.MessageService;
import com.sqx.modules.sys.entity.SysUserEntity;
import com.sqx.modules.sys.service.SysUserService;
import com.sqx.modules.utils.HttpClientUtil; import com.sqx.modules.utils.HttpClientUtil;
import com.sqx.modules.utils.InvitationCodeUtil; import com.sqx.modules.utils.InvitationCodeUtil;
import com.sqx.modules.utils.MD5Util; import com.sqx.modules.utils.MD5Util;
@@ -110,6 +112,8 @@ public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements
private CommonInfoService commonRepository; private CommonInfoService commonRepository;
@Autowired @Autowired
private DiscSpinningService discSpinningService; private DiscSpinningService discSpinningService;
@Autowired
private SysUserService sysUserService;
private ReentrantReadWriteLock reentrantReadWriteLock = new ReentrantReadWriteLock(true); private ReentrantReadWriteLock reentrantReadWriteLock = new ReentrantReadWriteLock(true);
@Override @Override
@@ -896,12 +900,9 @@ public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements
if (StringUtils.isEmpty(msg)) { if (StringUtils.isEmpty(msg)) {
return Result.error("验证码不能为空!"); return Result.error("验证码不能为空!");
} }
Msg msg1 = null; Msg msg1 = msgDao.findByPhoneAndCode(phone, msg);
if (!"147258".equals(msg)) { if (msg1 == null) {
msg1 = msgDao.findByPhoneAndCode(phone, msg); return Result.error("验证码不正确!");
if (msg1 == null) {
return Result.error("验证码不正确!");
}
} }
userInfo = new UserEntity(); userInfo = new UserEntity();
UserEntity userEntity = null; UserEntity userEntity = null;
@@ -921,6 +922,11 @@ public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements
} }
if (StringUtils.isEmpty(qdCode)) { if (StringUtils.isEmpty(qdCode)) {
qdCode = userEntity.getQdCode(); qdCode = userEntity.getQdCode();
} else {
SysUserEntity sysUserEntity = sysUserService.selectSysUserByQdCode(qdCode);
if (sysUserEntity == null) {
return Result.error("请使用正确的渠道码!");
}
} }
userInfo.setQdCode(qdCode); userInfo.setQdCode(qdCode);
userInfo.setPhone(phone); userInfo.setPhone(phone);