@Getter
public static final class ImportedKnowledgeEvent extends ApplicationEvent {
    private final Knowledge knowledge;
    private final KWDocument document;
    // 構(gòu)造器1：只有knowledge
    public ImportedKnowledgeEvent(Object source, Knowledge knowledge) {
        super(source);
        this.knowledge = knowledge;
        this.document = null;
    }
    // 構(gòu)造器2：knowledge + document
    public ImportedKnowledgeEvent(Object source, Knowledge knowledge, KWDocument document) {
        super(source);
        this.knowledge = knowledge;
        this.document = document;
    }
}

@Service
public class KnowledgeService {
    @Autowired
    protected ApplicationEventPublisher eventPublisher;
    public void imports() {
        // 發(fā)布簡(jiǎn)單知識(shí)導(dǎo)入事件
        eventPublisher.publishEvent(new ImportedKnowledgeEvent(this, new Knowledge()));
        // 發(fā)布知識(shí)+文檔導(dǎo)入事件
        eventPublisher.publishEvent(new ImportedKnowledgeEvent(this, new Knowledge(), new KWDocument()));
    }
}

@Service
public class KnowledgeRagflowService extends KnowledgeService {
    @EventListener
    public void importedKnowledge(KnowledgeService.ImportedKnowledgeEvent event) {
        if (event.getDocument() != null) {
            dealDocument(event.getKnowledge(), event.getDocument());
        } else {
            dealKnowledge(event.getKnowledge());
        }
    }
    private void dealDocument(Knowledge knowledge, Document document) {
        // 處理文檔邏輯
    }
    private void dealKnowledge(Knowledge knowledge) {
        // 處理知識(shí)邏輯
    }
}

@EventListener(condition = "#event.document != null")
public void handleDocumentEvent(ImportedKnowledgeEvent event) {
    // 僅處理包含document的事件
}

@Async
@EventListener
public void asyncHandleEvent(ImportedKnowledgeEvent event) {
    // 異步處理耗時(shí)操作
}

@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(25);
        executor.initialize();
        return executor;
    }
}

@Order(1)
@EventListener
public void firstListener(ImportedKnowledgeEvent event) {
    // 最先執(zhí)行
}
@Order(2)
@EventListener
public void secondListener(ImportedKnowledgeEvent event) {
    // 其次執(zhí)行
}

@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
public void afterCommitEvent(ImportedKnowledgeEvent event) {
    // 事務(wù)提交后執(zhí)行
}

@EventListener
public void handleEvent(ImportedKnowledgeEvent event) {
    try {
        // 業(yè)務(wù)處理
    } catch (Exception e) {
        // 1. 記錄錯(cuò)誤日志
        // 2. 發(fā)布錯(cuò)誤處理事件
        // 3. 重試機(jī)制（如Spring Retry）
    }
}

@SpringBootTest
class KnowledgeEventTest {
    @Autowired
    private ApplicationEventPublisher eventPublisher;
    @MockBean
    private KnowledgeRagflowService ragflowService;
    @Test
    void shouldTriggerListenerWhenPublishEvent() {
        // 準(zhǔn)備測(cè)試事件
        ImportedKnowledgeEvent event = new ImportedKnowledgeEvent(this, new Knowledge());
        // 發(fā)布事件
        eventPublisher.publishEvent(event);
        // 驗(yàn)證監(jiān)聽器調(diào)用
        verify(ragflowService, timeout(1000)).importedKnowledge(event);
    }
}

@EventListener
public void onApplicationReady(ContextRefreshedEvent event) {
    // 應(yīng)用啟動(dòng)完成后初始化資源
}

@EventListener
public void auditLog(ImportedKnowledgeEvent event) {
    log.info("Knowledge imported: {}", event.getKnowledge().getId());
}

// 使用標(biāo)記防止循環(huán)
public void imports() {
    if (!EventContext.isEventProcessing()) {
        eventPublisher.publishEvent(...);
    }
}