rakor
/
mobilebroken
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

移除代理商过期处理定时任务

This commit is contained in:
曹鹏飞 2026-01-19 15:29:55 +08:00
parent 392956408e
commit 1d0e85f6f0
2 changed files with 37 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
nflg-mobilebroken-admin/src/main/java/com/nflg/mobilebroken/admin/task/AppUserScheduledTasks.java
View File

@ -18,38 +18,38 @@ import java.util.stream.Collectors;
@Slf4j
public class AppUserScheduledTasks {
@Resource
private IAppUserService appUserService;
/**
* 禁用已过期代理商
* 每天午夜12点执行一次
*/
@Transactional
@Scheduled(cron = "0 0 0 * * ?")
public void disableExpiredAppUser() {
List<AppUser> primaryAppUsers=appUserService.lambdaQuery()
.eq(AppUser::getIsPrimary, true)
.lt(AppUser::getExpireTime, LocalDateTime.now().toLocalDate())
.list();
if (CollectionUtil.isNotEmpty(primaryAppUsers)){
appUserService.lambdaUpdate()
.set(AppUser::getState, UserState.Disabled.getState())
.set(AppUser::getUpdateTime, LocalDateTime.now())
.ne(AppUser::getState, UserState.Disabled.getState())
.in(AppUser::getId, primaryAppUsers.stream().map(AppUser::getId).collect(Collectors.toList()))
.update();
for (AppUser primaryUser : primaryAppUsers) {
List<AppUser> children=appUserService.getChildren(primaryUser);
if (CollectionUtil.isNotEmpty(children)){
appUserService.lambdaUpdate()
.set(AppUser::getState, UserState.Disabled.getState())
.set(AppUser::getUpdateTime, LocalDateTime.now())
.ne(AppUser::getState, UserState.Disabled.getState())
.in(AppUser::getId, children.stream().map(AppUser::getId).collect(Collectors.toList()))
.update();
}
}
}
}
// @Resource
// private IAppUserService appUserService;
//
// /**
// * 禁用已过期代理商
// * 每天午夜12点执行一次
// */
// @Transactional
// @Scheduled(cron = "0 0 0 * * ?")
// public void disableExpiredAppUser() {
// List<AppUser> primaryAppUsers=appUserService.lambdaQuery()
// .eq(AppUser::getIsPrimary, true)
// .lt(AppUser::getExpireTime, LocalDateTime.now().toLocalDate())
// .list();
// if (CollectionUtil.isNotEmpty(primaryAppUsers)){
// appUserService.lambdaUpdate()
// .set(AppUser::getState, UserState.Disabled.getState())
// .set(AppUser::getUpdateTime, LocalDateTime.now())
// .ne(AppUser::getState, UserState.Disabled.getState())
// .in(AppUser::getId, primaryAppUsers.stream().map(AppUser::getId).collect(Collectors.toList()))
// .update();
// for (AppUser primaryUser : primaryAppUsers) {
// List<AppUser> children=appUserService.getChildren(primaryUser);
// if (CollectionUtil.isNotEmpty(children)){
// appUserService.lambdaUpdate()
// .set(AppUser::getState, UserState.Disabled.getState())
// .set(AppUser::getUpdateTime, LocalDateTime.now())
// .ne(AppUser::getState, UserState.Disabled.getState())
// .in(AppUser::getId, children.stream().map(AppUser::getId).collect(Collectors.toList()))
// .update();
// }
// }
// }
// }
}

6
nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/service/impl/AppUserServiceImpl.java
View File

@ -574,7 +574,7 @@ public class AppUserServiceImpl extends ServiceImpl<AppUserMapper, AppUser> impl
if (request.getEnable()) {
lambdaUpdate()
.set(AppUser::getState, UserState.Activated.getState())
.set(AppUser::getUpdateBy, AdminUserUtil.getUserId())
.set(AppUser::getUpdateBy, AdminUserUtil.getUserName())
.set(AppUser::getUpdateTime, LocalDateTime.now())
.eq(AppUser::getIsDel, false)
.in(AppUser::getId, request.getIds())
@ -582,7 +582,7 @@ public class AppUserServiceImpl extends ServiceImpl<AppUserMapper, AppUser> impl
} else {
lambdaUpdate()
.set(AppUser::getState, UserState.Disabled.getState())
.set(AppUser::getUpdateBy, AdminUserUtil.getUserId())
.set(AppUser::getUpdateBy, AdminUserUtil.getUserName())
.set(AppUser::getUpdateTime, LocalDateTime.now())
.eq(AppUser::getIsDel, false)
.in(AppUser::getId, request.getIds())
@ -596,7 +596,7 @@ public class AppUserServiceImpl extends ServiceImpl<AppUserMapper, AppUser> impl
if (CollectionUtil.isNotEmpty(companyIds)) {
lambdaUpdate()
.set(AppUser::getState, UserState.Disabled.getState())
.set(AppUser::getUpdateBy, AdminUserUtil.getUserId())
.set(AppUser::getUpdateBy, AdminUserUtil.getUserName())
.set(AppUser::getUpdateTime, LocalDateTime.now())
.eq(AppUser::getIsDel, false)
.eq(AppUser::getIsPrimary, false)