package com.ruoyi.task.event;

import com.ruoyi.common.core.event.FollowupCompletedEvent;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Component;

import java.util.Date;

/**
 * 随访完成事件发布器。
 *
 * <p>任务模块在子任务状态更新为已完成（sendstate=6）后发布事件，
 * 档案等下游模块通过 {@code @TransactionalEventListener} 异步消费。</p>
 *
 * @author ruoyi
 * @date 2026-11-11
 */
@Slf4j
@Component
public class FollowupCompletedEventPublisher {

    @Autowired
    private ApplicationEventPublisher applicationEventPublisher;

    public void publish(Long subId) {
        if (subId == null) {
            return;
        }
        try {
            applicationEventPublisher.publishEvent(new FollowupCompletedEvent(subId, new Date()));
        } catch (Exception e) {
            log.error("发布随访完成事件失败，subId={}", subId, e);
        }
    }
}