package com.ruoyi.inhospvisit.api;

import com.ruoyi.common.core.service.dto.VisitAgainSubtaskDto;
import com.ruoyi.inhospvisit.service.InhospVisitTaskService;
import com.ruoyi.inhospvisit.service.TaskGroupCycleRoller;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * {@link InhospVisitApi} 的唯一内部实现（<b>常驻 Bean</b>）。
 *
 * <p>⚠️ <b>调用方不要直接注入本类</b>，应注入常驻门面 {@link InhospVisitFacade}
 * —— 门面负责开关判断与降级，本类只做转发。
 *
 * <p>⚠️ <b>刻意不加 {@code @ConditionalOnProperty}</b>：该注解只在启动时求值一次，
 * 无法支持"改完 {@code sys_config} 参数即时生效"；开关判断统一由门面在运行时做。
 *
 * <h3>当前接入状态（第 10 步）</h3>
 * <table border="1">
 *   <tr><th>方法</th><th>状态</th></tr>
 *   <tr><td>{@link #dealOutHospInfo(String)}</td>
 *       <td>✅ 已接入 {@link InhospVisitTaskService}（第 10 步切换）</td></tr>
 *   <tr><td>{@link #rollTaskGroupCycle()}</td>
 *       <td>✅ 已接入 {@link TaskGroupCycleRoller}（第 9 步搬迁）</td></tr>
 *   <tr><td>{@link #dealOutHospInfoBySchedule(String)}</td>
 *       <td>⏸ 未接入：该方法本次不搬（含手术分支与任务组 builder，属第二批
 *           {@code ruoyi-othervisit} 范围），仍由 smartor 的实现承接。
 *           {@code RyTask} 在本步<b>不改这一处</b>。</td></tr>
 *   <tr><td>{@link #buildAgainVisitDraft}</td>
 *       <td>⏸ 未接入：「随访超时→再次随访」链路；原实现调
 *           {@code boxedServiceSubtask}，需把 {@code pat_med_operation_item} 维度也考虑进来。
 *           本次保持现状（返回空结果 = 不生成），并在 {@code RyTask} 侧暂不改这一处。</td></tr>
 *   <tr><td>{@link #generatePublicitySubtask}</td>
 *       <td>✅ 已接入（宣教模块回调本模块建子任务）</td></tr>
 * </table>
 */
@Slf4j
@Component
public class DefaultInhospVisitApi implements InhospVisitApi {

    @Autowired
    private InhospVisitTaskService inhospVisitTaskService;

    @Autowired
    private TaskGroupCycleRoller taskGroupCycleRoller;

    @Autowired
    private com.ruoyi.inhospvisit.service.InhospSubtaskWriter inhospSubtaskWriter;

    @Autowired
    private com.ruoyi.inhospvisit.mapper.VisitInhospMapper inhospMapper;

    @Autowired
    private com.ruoyi.inhospvisit.mapper.VisitArchiveMapper archiveMapper;

    @Autowired
    private org.springframework.beans.factory.ObjectProvider<com.ruoyi.common.core.service.OtherVisitApi> otherVisitApiProvider;

    @Autowired
    private org.springframework.beans.factory.ObjectProvider<com.ruoyi.common.core.service.OuthospVisitApi> outhospVisitApiProvider;

    private com.ruoyi.common.core.service.OtherVisitApi otherVisitApi() {
        if (otherVisitApiProvider == null) {
            return null;
        }
        try {
            return otherVisitApiProvider.stream().findFirst().orElse(null);
        } catch (Exception e) {
            log.warn("【出入院随访】获取 OtherVisitApi 失败：{}", e.toString());
            return null;
        }
    }

    private com.ruoyi.common.core.service.OuthospVisitApi outhospVisitApi() {
        if (outhospVisitApiProvider == null) {
            return null;
        }
        try {
            return outhospVisitApiProvider.stream().findFirst().orElse(null);
        } catch (Exception e) {
            log.warn("【出入院随访】获取 OuthospVisitApi 失败：{}", e.toString());
            return null;
        }
    }

    @Override
    public boolean isEnabled() {
        // 门面已经判过开关；这里表示"实现存在"
        return true;
    }

    @Override
    public int dealOutHospInfo(String config) {
        return inhospVisitTaskService.dealOutHospInfo(config);
    }

    /**
     * ✅ 已接入：转发到 {@code com.ruoyi.common.core.service.OtherVisitApi}（smartor 过渡实现）。
     * <p>
     * 该方法<b>本身未搬迁</b>（含手术分支与任务组 builder，属第二批 {@code ruoyi-othervisit}），
     * 但端点已迁进本模块，所以这里只做转发 —— 行为与原 Controller 直接调
     * {@code iPatMedInhospService.dealOutHospInfoBySchedule(config)} 完全一致。
     */
    @Override
    public int dealOutHospInfoBySchedule(String config) {
        com.ruoyi.common.core.service.OtherVisitApi api = otherVisitApi();
        if (api == null) {
            log.warn("【出入院随访】OtherVisitApi 不可用，dealOutHospInfoBySchedule 跳过。config={}", config);
            return 0;
        }
        return api.dealOutHospInfoBySchedule(config);
    }

    /**
     * ✅ 已接入：转发到 {@code com.ruoyi.common.core.service.OtherVisitApi}（smartor 过渡实现）。
     * <p>
     * 手术随访本次未搬（属第二批 {@code ruoyi-othervisit}），端点已迁进本模块，故此处只转发。
     */
    @Override
    public int addOperationSubTask(String config) {
        com.ruoyi.common.core.service.OtherVisitApi api = otherVisitApi();
        if (api == null) {
            log.warn("【出入院随访】OtherVisitApi 不可用，addOperationSubTask 跳过。config={}", config);
            return 0;
        }
        return api.addOperationSubTask(config);
    }

    /**
     * ✅ 已接入：转发到 {@code com.ruoyi.common.core.service.OuthospVisitApi}（smartor 过渡实现）。
     * <p>
     * 门诊随访属第二批 {@code ruoyi-outpatientvisit}，本次只接转发。
     * 站点判断（{@code active != "xh"}）在 Controller 里，与原实现位置一致。
     */
    @Override
    public int dealOutpatientInfo() {
        com.ruoyi.common.core.service.OuthospVisitApi api = outhospVisitApi();
        if (api == null) {
            log.warn("【出入院随访】OuthospVisitApi 不可用（门诊随访模块未装配），dealOutpatientInfo 跳过。");
            return 0;
        }
        return api.dealOutpatientInfo();
    }

    @Override
    public int rollTaskGroupCycle() {
        return taskGroupCycleRoller.rollCycleTasks();
    }

    /**
     * ⏸ 未接入（见类注释）：返回"未找到出入院记录"，调用方会跳过该条（与原实现的 continue 语义一致，
     * 但不会因为"模块未接入"而误生成子任务）。
     */
    @Override
    public VisitAgainSubtaskDto buildAgainVisitDraft(String orgid, Long inhospid, Long newTaskId, Long sendstate) {
        log.warn("【出入院随访】buildAgainVisitDraft 本次未接入（随访超时→再次随访链路属后续范围），"
                + "返回空结果。orgid={}, inhospid={}", orgid, inhospid);
        return InhospVisitFacade.emptyAgainDraft("本次未接入（后续范围）");
    }

    /**
     * 宣教模块回调：为某患者生成一条宣教类子任务（type=0/4/5）。
     * <p>
     * 逐行对应原 {@code dealOutHospInfo} 里那两段宣教的最终动作
     * —— 即 {@code writeInSubTask(taskId, true, patMedInhosp, patArchive, type, config)}。
     * 这里按 inhospid 重新加载出入院记录与患者档案，然后委托给
     * {@link com.ruoyi.inhospvisit.service.InhospSubtaskWriter}（<b>boxed 的 type=0/4/5 分支全仓只有一份</b>）。
     */
    @Override
    public boolean generatePublicitySubtask(Long taskid, Long patid, Long inhospid, int type, String config) {
        if (inhospid == null) {
            log.warn("【出入院随访】generatePublicitySubtask 缺少 inhospid，跳过。taskid={}, patid={}, type={}",
                    taskid, patid, type);
            return false;
        }
        com.ruoyi.inhospvisit.domain.row.VisitInhospRow inhosp = inhospMapper.selectByInhospid(inhospid);
        if (inhosp == null) {
            log.warn("【出入院随访】generatePublicitySubtask 查不到出入院记录，跳过。inhospid={}", inhospid);
            return false;
        }
        // 患者档案：原实现传 patMedInhosp.patid（不是宣教模块传来的 patid），这里保持一致
        com.ruoyi.common.core.service.dto.VisitArchiveRow archive = archiveMapper.selectByPatid(inhosp.getPatid());
        if (archive == null) {
            log.warn("【出入院随访】generatePublicitySubtask 查不到患者档案，跳过。patid={}", inhosp.getPatid());
            return false;
        }
        // check=true：让 writeInSubTask 内部做去重/再入院校验（原实现两段宣教都是 true）
        inhospSubtaskWriter.writeInSubTask(taskid, true, inhosp, archive, type, config);
        return true;
    }
}