package jnpf.elnService.impl;

import jnpf.elnEntity.field.ElnFieldForms;
import jnpf.elnEntity.field.ElnFieldVersionEntity;
import jnpf.elnEntity.runtime.ElnRecordFieldValueEntity;
import jnpf.exception.DataException;
import jnpf.lims.api.model.ElnSourcePropertyRef;
import jnpf.lims.api.model.ElnSourceSnapshot;

import java.time.Instant;
import java.util.Date;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;

/** Shared validation for configured snapshots at creation and explicit synchronization. */
final class ElnConfiguredSourceValues {
    private ElnConfiguredSourceValues() { }

    static ElnSourcePropertyRef reference(ElnFieldForms.Read read) {
        if (read.getPropertyRevision() == null || read.getPropertyRevision() < 1
                || read.getProperty() == null || !read.getProperty().matches("[a-zA-Z][a-zA-Z0-9_.-]{0,79}")) {
            throw new DataException("LIMS 来源固定版本无效");
        }
        return new ElnSourcePropertyRef(read.getProperty(), read.getPropertyRevision());
    }

    static Map<ElnSourcePropertyRef, ElnSourceSnapshot> index(String itemId,
            List<ElnSourcePropertyRef> requested, List<ElnSourceSnapshot> snapshots) {
        if (snapshots == null) throw new DataException("LIMS 来源快照响应为空");
        Map<ElnSourcePropertyRef, ElnSourceSnapshot> result = new LinkedHashMap<>();
        for (ElnSourceSnapshot snapshot : snapshots) {
            if (snapshot == null || !Objects.equals(itemId, snapshot.getSourceRef())) {
                throw new DataException("LIMS 来源快照检验项不一致");
            }
            ElnSourcePropertyRef ref = new ElnSourcePropertyRef(snapshot.getPropertyCode(), snapshot.getPropertyRevision());
            if (!requested.contains(ref) || result.putIfAbsent(ref, snapshot) != null) {
                throw new DataException("LIMS 来源快照版本不一致或重复");
            }
        }
        if (result.size() != new java.util.HashSet<>(requested).size()) {
            throw new DataException("LIMS 来源快照缺少固定版本结果");
        }
        return result;
    }

    static void apply(ElnRecordFieldValueEntity value, ElnFieldVersionEntity version, ElnSourceSnapshot snapshot) {
        if (snapshot == null) throw new DataException("LIMS 来源快照为空");
        boolean missing = "MISSING".equals(snapshot.getOutcomeCode()) || "NOT_APPLICABLE".equals(snapshot.getOutcomeCode());
        if (!"SUCCESS".equals(snapshot.getOutcomeCode()) && !missing) {
            throw new DataException("LIMS 来源取数失败");
        }
        if (missing && Integer.valueOf(1).equals(version.getShifouBitian())) {
            throw new DataException("必填 LIMS 来源缺失或不适用");
        }
        if (!Objects.equals(version.getShujuLeixing(), snapshot.getDataType())
                && !("CHECKBOX".equals(version.getShujuLeixing()) && "BOOLEAN".equals(snapshot.getDataType()))
                && !("TEXT".equals(snapshot.getDataType()) && ("TEXTAREA".equals(version.getShujuLeixing())
                        || "SELECT".equals(version.getShujuLeixing())))) {
            throw new DataException("LIMS 来源类型与固定字段版本不兼容");
        }
        if (!missing && (snapshot.getValue() == null || snapshot.getValue().trim().isEmpty())) {
            throw new DataException("LIMS 来源成功结果不能为空");
        }
        Date acquiredAt;
        try { acquiredAt = Date.from(Instant.parse(snapshot.getAcquiredAt())); }
        catch (RuntimeException invalid) { throw new DataException("LIMS 来源获取时间无效"); }
        if (missing) {
            value.setZhiWenben(null);
            value.setZhiShuzhi(null);
            value.setZhiRiqi(null);
        } else if ("DECIMAL".equals(snapshot.getDataType())) {
            try {
                java.math.BigDecimal number = new java.math.BigDecimal(snapshot.getValue());
                java.math.BigDecimal normalized = number.stripTrailingZeros();
                if (normalized.scale() > 18 || (long) normalized.precision() - normalized.scale() > 20) {
                    throw new DataException("LIMS 来源数值超出快照精度范围，不能舍入保存");
                }
                value.setZhiShuzhi(number);
            }
            catch (NumberFormatException invalid) { throw new DataException("LIMS 来源数值无效"); }
        } else if ("DATE".equals(snapshot.getDataType())) {
            try { value.setZhiRiqi(java.sql.Date.valueOf(java.time.LocalDate.parse(snapshot.getValue()))); }
            catch (RuntimeException invalid) { throw new DataException("LIMS 来源日期无效"); }
        } else if ("DATETIME".equals(snapshot.getDataType())) {
            try {
                java.time.temporal.TemporalAccessor parsed = java.time.format.DateTimeFormatter.ISO_DATE_TIME
                        .parseBest(snapshot.getValue(), java.time.OffsetDateTime::from, java.time.LocalDateTime::from);
                if (parsed.get(java.time.temporal.ChronoField.NANO_OF_SECOND) != 0) {
                    throw new DataException("LIMS 来源时间超出快照秒级精度，不能舍入保存");
                }
                value.setZhiRiqi(parsed instanceof java.time.OffsetDateTime
                        ? Date.from(((java.time.OffsetDateTime) parsed).toInstant())
                        : java.sql.Timestamp.valueOf((java.time.LocalDateTime) parsed));
            }
            catch (DataException invalid) { throw invalid; }
            catch (RuntimeException invalid) { throw new DataException("LIMS 来源时间无效"); }
        } else if ("BOOLEAN".equals(snapshot.getDataType())) {
            if (!"true".equals(snapshot.getValue()) && !"false".equals(snapshot.getValue())) {
                throw new DataException("LIMS 来源布尔值无效");
            }
            value.setZhiWenben(snapshot.getValue());
        } else {
            value.setZhiWenben(snapshot.getValue());
        }
        value.setZhiLaiyuan("LIMS_TASK");
        value.setYuanShuxing(snapshot.getPropertyCode());
        value.setYuanShuxingBanben(snapshot.getPropertyRevision());
        value.setYuanQuzhiZhuangtai(snapshot.getOutcomeCode());
        value.setYuanQuzhiYuanyin(snapshot.getReasonCode());
        value.setYuanXueyuan(snapshot.getLineage());
        value.setYuanYinyongLeixing("LIMS_TASK");
        value.setYuanYinyongId(snapshot.getSourceRef());
        value.setYuanHuoquShijian(acquiredAt);
    }
}