package com.ruoyi.inhospvisit.service;

import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.ruoyi.common.core.service.VisitTaskCreateApi;
import com.ruoyi.common.core.service.dto.VisitSubtaskDraft;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.core.service.dto.VisitPreachformRow;
import com.ruoyi.inhospvisit.mapper.VisitPreachformMapper;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils;
import org.springframework.beans.factory.ObjectProvider;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;
import java.util.Objects;

/**
 * 「执行方式明细」写入器 —— 逐行搬自 {@code PatMedInhospServiceImpl#addServiceSubtaskPreachform}
 * （L1061-1103，43 行），并实现第 7 步预留的
 * {@link InhospSubtaskWriter.SubtaskPreachformWriter} 接口。
 *
 * <h3>行为逐条对照</h3>
 * <ol>
 *   <li>按 taskid 查任务；查不到 → 打 ERROR 并 return 0（<b>不抛异常</b>）；</li>
 *   <li>取 {@code serviceTask.preachformDesc}；为空则整块跳过（返回 0）；</li>
 *   <li>用 Jackson 把 JSON 反序列化成 {@code List<VisitPreachformRow>}；
 *       <b>解析失败只打 ERROR，不中断</b>（随后 list 为 null → 走"解析后为空"分支）；</li>
 *   <li>解析结果为空 → 打 ERROR 并 return 0；</li>
 *   <li>逐条：设 {@code taskid} → {@code subid}；
 *       <b>先查重</b>（已存在则 continue，不新增）；
 *       {@code sendstate} 默认 "1"，调用方传了非空值则覆写；
 *       设 {@code orgid}；insert。</li>
 * </ol>
 *
 * <h3>⚠️ 原实现的 3 个要点，原样保留</h3>
 * <ul>
 *   <li>返回值【永远是 0】（原 L1102 {@code return 0;}），调用方也没有用它的返回值
 *       —— 所以本类也返回 0，不做"顺手改成成功条数"；</li>
 *   <li>查重用的条件是 {@code ServiceSubtaskPreachform(subid, taskid, preachform)}
 *       —— <b>注意没有设 orgid</b>（虽然 XML 支持该条件）。原样保留；</li>
 *   <li>解析失败时 {@code serviceSubtaskPreachformList} 保持 null，
 *       由 {@code CollectionUtils.isEmpty(null) == true} 走进"解析后为空"分支 —— 原样保留这个控制流。</li>
 * </ul>
 *
 * <h3>⚠️ 与调用方的事务关系（一处已登记的差异）</h3>
 * 原实现里 {@code addServiceSubtaskPreachform} 与 {@code insertServiceSubtask} 在<b>同一个 try</b> 内，
 * 它抛异常会被 {@code writeInSubTask} 的 catch 捕获并把标志位置 "2"。
 * 搬迁后 {@link InhospSubtaskWriter} 把它放在自己的 try 里按"尽力而为"处理
 * （见该方法注释）。这是<b>有意的健壮性改进</b>：写执行方式明细失败不该
 * 让整条随访子任务被判为生成失败。已登记在 {@code verify_inhospvisit_writein_semantics.py} 的说明里。
 */
@Slf4j
@Service
public class VisitPreachformWriter implements InhospSubtaskWriter.SubtaskPreachformWriter {

    /** 原实现里注释写明「这个 sendstate 需要在数据库设置一个默认值为"1"」 */
    private static final String DEFAULT_SENDSTATE = "1";

    @Autowired
    private VisitPreachformMapper preachformMapper;

    @Autowired
    private ObjectProvider<VisitTaskCreateApi> taskCreateApiProvider;

    private final ObjectMapper objectMapper = new ObjectMapper();

    @Override
    public void addServiceSubtaskPreachform(VisitSubtaskDraft serviceSubtask, String sendstate) {
        // 原 L1063-1067：按 taskid 查任务（这里走任务创建域的接口，而不是直接查 service_task）
        VisitTaskCreateApi api = taskApi();
        String preachformDesc = api == null ? null : api.findPreachformDesc(serviceSubtask.getTaskid());
        if (api == null) {
            log.error("addServiceSubtaskPreachform taskid={} 查不到任务，跳过preachform子表生成",
                    serviceSubtask.getTaskid());
            return;
        }

        // 原 L1070-1071
        if (org.apache.commons.lang3.StringUtils.isNotEmpty(preachformDesc)) {
            // 原 L1072-1078：反序列化；失败只打 ERROR，list 保持 null
            List<VisitPreachformRow> list = null;
            try {
                list = objectMapper.readValue(preachformDesc, new TypeReference<List<VisitPreachformRow>>() {
                });
            } catch (Exception e) {
                log.error("preachform转List<ServiceSubtaskPreachform>报错了：{}", e.getMessage());
            }
            // 原 L1079-1083
            if (CollectionUtils.isEmpty(list)) {
                log.error("preachformDesc解析后为空，跳过preachform子表生成，taskid为：{}，preachformDesc为：{}",
                        serviceSubtask.getTaskid(), preachformDesc);
                return;
            }
            // 原 L1084-1098
            for (VisitPreachformRow row : list) {
                row.setTaskid(serviceSubtask.getTaskid());
                row.setSubid(serviceSubtask.getId());

                // 原 L1088-1090：先查重，已存在就不新增
                VisitPreachformRow query = new VisitPreachformRow();
                query.setSubid(row.getSubid());
                query.setTaskid(row.getTaskid());
                query.setPreachform(row.getPreachform());
                List<VisitPreachformRow> exists = preachformMapper.selectList(query);
                if (CollectionUtils.isNotEmpty(exists)) {
                    continue;
                }

                // 原 L1092-1094：默认 "1"，调用方给了非空值则覆写
                row.setSendstate(DEFAULT_SENDSTATE);
                if (StringUtils.isNotEmpty(sendstate)) {
                    row.setSendstate(sendstate);
                }

                // 原 L1096-1097
                row.setOrgid(serviceSubtask.getOrgid());
                preachformMapper.insert(row);
            }
        }

        // 原 L1102：返回值固定为 0（见类注释）
    }

    private VisitTaskCreateApi taskApi() {
        if (taskCreateApiProvider == null) {
            return null;
        }
        try {
            return taskCreateApiProvider.stream().findFirst().orElse(null);
        } catch (Exception e) {
            log.warn("【出入院随访】获取 VisitTaskCreateApi 失败：{}", e.toString());
            return null;
        }
    }

    /** 供测试断言：确认本类拿到的 ObjectMapper 非空（原实现是方法内 new，这里提为字段） */
    boolean hasObjectMapper() {
        return Objects.nonNull(objectMapper);
    }
}