lywsvip/hsweb-framework
1
0
Fork 0
mirror of https://github.com/hs-web/hsweb-framework.git synced 2026-06-06 14:15:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

增加UserStateChangedEvent

Browse Source
This commit is contained in:
zhou-hao
2021-10-28 09:09:51 +08:00
parent c9af0310db
commit 08bdc14973
2 changed files with 29 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
hsweb-system/hsweb-system-authorization/hsweb-system-authorization-api/src/main/java/org/hswebframework/web/system/authorization/api/event/UserStateChangedEvent.java Normal file
View File

@@ -0,0 +1,20 @@
package org.hswebframework.web.system.authorization.api.event;
import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.Setter;
import org.hswebframework.web.event.DefaultAsyncEvent;
import java.util.List;
@Getter
@Setter
@AllArgsConstructor(staticName = "of")
public class UserStateChangedEvent extends DefaultAsyncEvent {
private List<String> userIdList;
private byte state;
}

15
hsweb-system/hsweb-system-authorization/hsweb-system-authorization-default/src/main/java/org/hswebframework/web/system/authorization/defaults/service/DefaultReactiveUserService.java
View File

@@ -13,10 +13,7 @@ import org.hswebframework.web.system.authorization.api.PasswordEncoder;
import org.hswebframework.web.system.authorization.api.PasswordValidator;
import org.hswebframework.web.system.authorization.api.UsernameValidator;
import org.hswebframework.web.system.authorization.api.entity.UserEntity;
import org.hswebframework.web.system.authorization.api.event.ClearUserAuthorizationCacheEvent;
import org.hswebframework.web.system.authorization.api.event.UserCreatedEvent;
import org.hswebframework.web.system.authorization.api.event.UserDeletedEvent;
import org.hswebframework.web.system.authorization.api.event.UserModifiedEvent;
import org.hswebframework.web.system.authorization.api.event.*;
import org.hswebframework.web.system.authorization.api.service.reactive.ReactiveUserService;
import org.reactivestreams.Publisher;
import org.springframework.beans.factory.annotation.Autowired;
@@ -113,7 +110,7 @@ public class DefaultReactiveUserService extends GenericReactiveCrudService<UserE
.execute()
.flatMap(__ -> new UserModifiedEvent(userEntity, passwordChanged).publish(eventPublisher))
.thenReturn(userEntity)
.doOnNext(e->{
.doOnNext(e -> {
eventPublisher.publishEvent(ClearUserAuthorizationCacheEvent.of(e.getId()));
});
});
@@ -160,7 +157,13 @@ public class DefaultReactiveUserService extends GenericReactiveCrudService<UserE
.set(UserEntity::getStatus, state)
.where()
.in(UserEntity::getId, list)
.execute())
.execute()
.flatMap(i -> UserStateChangedEvent
.of(list, state)
.publish(eventPublisher)
.thenReturn(i)
)
)
.defaultIfEmpty(0);
}