Merge branch 'feature/gongfu' into feature/data-permission

This commit is contained in:
曹鹏飞 2026-01-20 09:24:20 +08:00
commit e0579c4c5c
2 changed files with 37 additions and 37 deletions

View File

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

View File

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