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

refactor: 更新事件缓存实体数据到上下文 (#260)

Browse Source
This commit is contained in:
gyl
2023-12-04 11:16:31 +08:00
committed by GitHub
parent e75848eda6
commit 74c9bd4fbd
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
hsweb-commons/hsweb-commons-crud/src/main/java/org/hswebframework/web/crud/events/EntityEventListener.java
View File

@@ -1,7 +1,6 @@
package org.hswebframework.web.crud.events;
import lombok.AllArgsConstructor;
import lombok.RequiredArgsConstructor;
import lombok.Setter;
import org.apache.commons.collections.CollectionUtils;
@@ -32,7 +31,6 @@ import java.util.concurrent.atomic.AtomicReference;
import java.util.function.BiFunction;
import java.util.function.Supplier;
import static org.hswebframework.web.crud.events.EntityEventHelper.isDoFireEvent;
import static org.hswebframework.web.crud.events.EntityEventHelper.publishEvent;
@SuppressWarnings("all")
@@ -40,7 +38,10 @@ import static org.hswebframework.web.crud.events.EntityEventHelper.publishEvent;
public class EntityEventListener implements EventListener, Ordered {
public static final ContextKey<List<Object>> readyToDeleteContextKey = ContextKey.of("readyToDelete");
public static final ContextKey<List<Object>> readyToUpdateContextKey = ContextKey.of("readyToUpdate");
//更新前的数据
public static final ContextKey<List<Object>> readyToUpdateBeforeContextKey = ContextKey.of("readyToUpdateBefore");
//更新后的数据
public static final ContextKey<List<Object>> readyToUpdateAfterContextKey = ContextKey.of("readyToUpdateAfter");
private final ApplicationEventPublisher eventPublisher;
@@ -247,6 +248,8 @@ public class EntityEventListener implements EventListener, Ordered {
}
List<Object> after = createAfterData(list, context);
updated.set(Tuples.of(list, after));
context.set(readyToUpdateBeforeContextKey, list);
context.set(readyToUpdateAfterContextKey, after);
return sendUpdateEvent(list,
after,
entityType,