aidlab/aida_back
7
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

BUGFIX:登录邮箱精确匹配;

Browse Source
This commit is contained in:
shahaibo
2024-04-23 10:50:45 +08:00
parent faeb59bae5
commit c3ae729466
3 changed files with 56 additions and 56 deletions
Download Patch File Download Diff File Expand all files Collapse all files

106
src/main/java/com/ai/da/common/RabbitMQ/MQConsumer.java
View File

@@ -104,58 +104,58 @@ public class MQConsumer {
log.info("=============end listening==========="); log.info("=============end listening===========");
} }
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer1(Message msg, Channel channel) { // public void generateConsumer1(Message msg, Channel channel) {
generate(msg, channel, "consumer 1"); // generate(msg, channel, "consumer 1");
} // }
//
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer2(Message msg, Channel channel) { // public void generateConsumer2(Message msg, Channel channel) {
generate(msg, channel, "consumer 2"); // generate(msg, channel, "consumer 2");
} // }
//
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer3(Message msg, Channel channel) { // public void generateConsumer3(Message msg, Channel channel) {
generate(msg, channel, "consumer 3"); // generate(msg, channel, "consumer 3");
} // }
//
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer4(Message msg, Channel channel) { // public void generateConsumer4(Message msg, Channel channel) {
generate(msg, channel, "consumer 4"); // generate(msg, channel, "consumer 4");
} // }
//
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer5(Message msg, Channel channel) { // public void generateConsumer5(Message msg, Channel channel) {
generate(msg, channel, "consumer 5"); // generate(msg, channel, "consumer 5");
} // }
//
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer6(Message msg, Channel channel) { // public void generateConsumer6(Message msg, Channel channel) {
generate(msg, channel, "consumer 6"); // generate(msg, channel, "consumer 6");
} // }
//
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer7(Message msg, Channel channel) { // public void generateConsumer7(Message msg, Channel channel) {
generate(msg, channel, "consumer 7"); // generate(msg, channel, "consumer 7");
} // }
//
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer8(Message msg, Channel channel) { // public void generateConsumer8(Message msg, Channel channel) {
generate(msg, channel, "consumer 8"); // generate(msg, channel, "consumer 8");
} // }
//
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer9(Message msg, Channel channel) { // public void generateConsumer9(Message msg, Channel channel) {
generate(msg, channel, "consumer 9"); // generate(msg, channel, "consumer 9");
} // }
} }

2
src/main/java/com/ai/da/common/config/MyTaskScheduler.java
View File

@@ -19,7 +19,7 @@ public class MyTaskScheduler {
// 定时任务，每十五天执行一次 // 定时任务，每十五天执行一次
// @Scheduled(cron = "0 0 0 ? * MON") // @Scheduled(cron = "0 0 0 ? * MON")
@Scheduled(cron = "0 0 0 */15 * ?") // @Scheduled(cron = "0 0 0 */15 * ?")
public void checkExpiry() { public void checkExpiry() {
// 检测正式用户是否快要过期 // 检测正式用户是否快要过期
QueryWrapper<Account> qw = new QueryWrapper<>(); QueryWrapper<Account> qw = new QueryWrapper<>();

4
src/main/java/com/ai/da/service/impl/AccountServiceImpl.java
View File

@@ -289,8 +289,7 @@ public class AccountServiceImpl extends ServiceImpl<AccountMapper, Account> impl
private Account getOneByEmail(String email) { private Account getOneByEmail(String email) {
QueryWrapper<Account> queryWrapper = new QueryWrapper<>(); QueryWrapper<Account> queryWrapper = new QueryWrapper<>();
queryWrapper.lambda().eq(Account::getUserEmail, email); queryWrapper.eq("BINARY user_email", email);
queryWrapper.lambda().last("limit 1");
List<Account> accountList = accountMapper.selectList(queryWrapper); List<Account> accountList = accountMapper.selectList(queryWrapper);
if (CollectionUtil.isEmpty(accountList)) { if (CollectionUtil.isEmpty(accountList)) {
throw new BusinessException("email.does.not.exist", ResultEnum.PROMPT.getCode()); throw new BusinessException("email.does.not.exist", ResultEnum.PROMPT.getCode());
@@ -298,6 +297,7 @@ public class AccountServiceImpl extends ServiceImpl<AccountMapper, Account> impl
return accountList.get(0); return accountList.get(0);
} }
private Account getOneByUserName(String userName) { private Account getOneByUserName(String userName) {
QueryWrapper<Account> queryWrapper = new QueryWrapper<>(); QueryWrapper<Account> queryWrapper = new QueryWrapper<>();
queryWrapper.lambda().eq(Account::getUserName, userName); queryWrapper.lambda().eq(Account::getUserName, userName);