Commit 0bf213ef authored by suhuiguang's avatar suhuiguang

feat(综合搜索):增量数据同步调整

1.编辑时间适配器,监听对象调整为父类
parent 00d9342c
...@@ -3,7 +3,6 @@ package com.yeejoin.amos.boot.module.jg.biz.edit.event; ...@@ -3,7 +3,6 @@ package com.yeejoin.amos.boot.module.jg.biz.edit.event;
import com.yeejoin.amos.boot.module.jg.api.dto.BizRelationDataDto; import com.yeejoin.amos.boot.module.jg.api.dto.BizRelationDataDto;
import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta; import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta;
import lombok.Getter; import lombok.Getter;
import org.springframework.context.ApplicationEvent;
import org.typroject.tyboot.core.foundation.context.RequestContextModel; import org.typroject.tyboot.core.foundation.context.RequestContextModel;
import java.util.List; import java.util.List;
...@@ -12,18 +11,12 @@ import java.util.List; ...@@ -12,18 +11,12 @@ import java.util.List;
* @author Administrator * @author Administrator
*/ */
@Getter @Getter
public class BaseBizDataChangeEvent extends ApplicationEvent { public class BaseBizDataChangeEvent extends EmptyDataChangeEvent {
private final List<FieldChangeMeta> data; private final List<FieldChangeMeta> data;
private final RequestContextModel requestContext;
private final BizRelationDataDto bizRelationData;
public BaseBizDataChangeEvent(Object source, BizRelationDataDto bizRelationData, List<FieldChangeMeta> data, RequestContextModel requestContext) { public BaseBizDataChangeEvent(Object source, BizRelationDataDto bizRelationData, List<FieldChangeMeta> data, RequestContextModel requestContext) {
super(source); super(source, bizRelationData, requestContext);
this.data = data; this.data = data;
this.bizRelationData = bizRelationData;
this.requestContext = requestContext;
} }
} }
package com.yeejoin.amos.boot.module.jg.biz.reminder.core.event.adapter; package com.yeejoin.amos.boot.module.jg.biz.reminder.core.event.adapter;
import com.yeejoin.amos.boot.module.jg.biz.edit.event.BaseBizDataChangeEvent; import com.yeejoin.amos.boot.module.jg.biz.edit.event.BaseBizDataChangeEvent;
import com.yeejoin.amos.boot.module.jg.biz.edit.event.EmptyDataChangeEvent;
import com.yeejoin.amos.boot.module.jg.biz.reminder.core.event.EquipCreateOrEditEvent; import com.yeejoin.amos.boot.module.jg.biz.reminder.core.event.EquipCreateOrEditEvent;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
...@@ -18,9 +19,9 @@ public class BizDataChange2EditEventAdapter { ...@@ -18,9 +19,9 @@ public class BizDataChange2EditEventAdapter {
private final ApplicationEventPublisher publisher; private final ApplicationEventPublisher publisher;
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT, value = {BaseBizDataChangeEvent.class}) @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT, value = {EmptyDataChangeEvent.class})
@Transactional(propagation = Propagation.REQUIRES_NEW) @Transactional(propagation = Propagation.REQUIRES_NEW)
public void handleEventAsync(BaseBizDataChangeEvent event) { public void handleEventAsync(EmptyDataChangeEvent event) {
log.info("receive editEvent handleEventAAsync eventA={}", event); log.info("receive editEvent handleEventAAsync eventA={}", event);
try { try {
publisher.publishEvent(convertToEvent(event)); publisher.publishEvent(convertToEvent(event));
...@@ -30,7 +31,7 @@ public class BizDataChange2EditEventAdapter { ...@@ -30,7 +31,7 @@ public class BizDataChange2EditEventAdapter {
} }
private EquipCreateOrEditEvent convertToEvent(BaseBizDataChangeEvent eventA) { private EquipCreateOrEditEvent convertToEvent(EmptyDataChangeEvent eventA) {
return new EquipCreateOrEditEvent( return new EquipCreateOrEditEvent(
this, this,
eventA.getBizRelationData().getBizType(), eventA.getBizRelationData().getBizType(),
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment