package jnpf.dmsService;

import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import jnpf.dmsIntegration.audit.DmsBusinessChangeAudit;
import jnpf.dmsEntity.kanwu.DmsXiudingKanwuRow;
import jnpf.dmsMapper.DmsXiudingKanwuMapper;
import jnpf.exception.DataException;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import java.util.*;

/** Validates native handling rows and applies only the effective-revision side effect. */
@Service
@RequiredArgsConstructor
public class DmsXiudingKanwuService {
    private static final ObjectMapper JSON = new ObjectMapper();
    private final DmsXiudingKanwuMapper mapper;
    private final DmsBusinessChangeAudit audit;

    @Transactional(propagation = Propagation.MANDATORY, rollbackFor = Exception.class)
    public List<DmsXiudingKanwuRow> loadAndValidate(String tenantId, String auditId, String fileId, String baseVersionId) {
        List<DmsXiudingKanwuRow> handled = new ArrayList<>(mapper.selectHandlingForUpdate(tenantId, auditId));
        List<DmsXiudingKanwuRow> approved = mapper.selectApprovedForUpdate(tenantId, fileId, baseVersionId);
        Map<String, DmsXiudingKanwuRow> sources = new HashMap<>();
        for (DmsXiudingKanwuRow row : approved) {
            if (sources.put(row.getKanwuZixiangId(), row) != null) throw new DataException("勘误来源重复");
        }
        if (handled.size() != sources.size()) throw new DataException("已批准勘误已变化，请退回起草人逐条处理后重新批准");
        Set<String> seen = new HashSet<>();
        for (DmsXiudingKanwuRow row : handled) {
            DmsXiudingKanwuRow source = sources.get(row.getKanwuZixiangId());
            if (source == null || !seen.add(row.getKanwuZixiangId()) || !snapshot(row).equals(snapshot(source))
                    || !files(row.getFujian()).equals(files(source.getFujian()))) {
                throw new DataException("勘误来源或内容已变化，请重新核对并批准");
            }
            if (!Set.of("yixiugai_queren", "bucaina").contains(normalize(row.getChuliJielun()))
                    || blank(row.getChuliYuanyin()) || blank(row.getChuliRenId()) || row.getChuliShijian() == null) {
                throw new DataException("每条勘误必须填写处理结论、原因、处理人和处理时间");
            }
            row.setAlreadyProcessed("yes".equals(source.getShifouYichuli()));
        }
        handled.sort(Comparator.comparing(DmsXiudingKanwuRow::getKanwuZixiangId));
        return handled;
    }

    /** Must share the existing applyApproved transaction: a failure rolls back settlement too. */
    @Transactional(propagation = Propagation.MANDATORY, rollbackFor = Exception.class)
    public void complete(String tenantId, String auditId, List<DmsXiudingKanwuRow> verifiedRows) {
        for (DmsXiudingKanwuRow row : verifiedRows) {
            // Another effective revision may have processed the same record erratum already.
            // Preserve its first operator/time; the new decision stays in its native audit row.
            if (row.isAlreadyProcessed()) continue;
            Map<String, Object> before = processingState(tenantId, row.getKanwuZixiangId());
            if (mapper.markProcessed(tenantId, row) != 1) {
                throw new DataException("勘误台账回写失败，修订生效业务回写已回滚");
            }
            Map<String, Object> after = processingState(tenantId, row.getKanwuZixiangId());
            audit.record(tenantId, "DMS_REVISION_ERRATA_PROCESSED", "修订生效后回写勘误处理状态",
                    "dms_wenjian_kanwu_shenqing_zixiang", row.getKanwuZixiangId(), before, after,
                    row.getChuliYuanyin(), DmsBusinessChangeAudit.values(
                            "xiuding_shenhe_id", auditId, "xiuding_kanwu_id", row.getId(),
                            "kanwu_shenqing_id", row.getKanwuShenqingId(), "wenjian_id", row.getWenjianId(),
                            "banben_id", row.getBanbenId(), "wenjian_bianhao", row.getWenjianBianhao(),
                            "wenjian_mingcheng", row.getWenjianMingcheng(), "banbenhao", row.getBanbenhao(),
                            "chuli_jielun", row.getChuliJielun(), "chuli_ren_id", row.getChuliRenId(),
                            "chuli_shijian", row.getChuliShijian()));
        }
    }

    private Map<String, Object> processingState(String tenantId, String id) {
        Map<String, Object> state = mapper.selectProcessingState(tenantId, id);
        if (state == null) throw new DataException("勘误台账状态读取失败，修订生效业务回写已回滚");
        // 保留真实空值；处理决定时间与数据库实际回写时间分别记录。
        return DmsBusinessChangeAudit.values("shifou_yichuli", state.get("shifou_yichuli"),
                "chuliren", state.get("chuliren"), "chuli_shijian", state.get("chuli_shijian"));
    }

    private static List<String> snapshot(DmsXiudingKanwuRow row) {
        return Arrays.asList(normalize(row.getKanwuShenqingId()), normalize(row.getWenjianId()),
                normalize(row.getBanbenId()), normalize(row.getWenjianBianhao()), normalize(row.getWenjianMingcheng()),
                normalize(row.getBanbenhao()), normalize(row.getKanwuWeizhi()), normalize(row.getKanwuNeirong()),
                normalize(row.getXiugaiJianyi()), normalize(row.getKanwuYuanyin()));
    }

    private static JsonNode files(String value) {
        try {
            JsonNode node = JSON.readTree(blank(value) ? "[]" : value);
            if (!node.isArray()) throw new DataException("勘误附件格式无效");
            return node;
        } catch (DataException e) { throw e; }
        catch (Exception e) { throw new DataException("勘误附件格式无效"); }
    }
    private static String normalize(String value) { return value == null ? "" : value; }
    private static boolean blank(String value) { return value == null || value.isBlank(); }
}