完成数据库定时解封低频同步(凌晨3点),主要还是依赖redis实时同步
This commit is contained in:
26
src/main/java/com/bao/dating/task/UserBanScheduleTask.java
Normal file
26
src/main/java/com/bao/dating/task/UserBanScheduleTask.java
Normal file
@@ -0,0 +1,26 @@
|
|||||||
|
package com.bao.dating.task;
|
||||||
|
|
||||||
|
import com.bao.dating.mapper.UserBanMapper;
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
||||||
|
import org.springframework.scheduling.annotation.Scheduled;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
|
@Slf4j
|
||||||
|
@Component
|
||||||
|
@EnableScheduling
|
||||||
|
public class UserBanScheduleTask {
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private UserBanMapper userBanMapper;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 每天凌晨 3 点同步过期封禁
|
||||||
|
*/
|
||||||
|
@Scheduled(cron = "0 0 3 * * ?")
|
||||||
|
public void syncExpiredUserBan() {
|
||||||
|
int rows = userBanMapper.updateExpiredBans();
|
||||||
|
log.info("封禁同步任务执行完成,解封 {} 个用户", rows);
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user