package jnpf.elnService.impl;

import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import jnpf.elnEntity.runtime.ElnRecordEntity;
import jnpf.elnEntity.runtime.ElnRecordFieldValueEntity;
import jnpf.elnEntity.template.ElnTemplateBindingEntity;
import jnpf.elnEntity.template.ElnTemplateCrossReferenceEntity;
import jnpf.elnMapper.ElnRecordFieldValueMapper;
import jnpf.elnMapper.ElnTemplateCrossReferenceMapper;
import jnpf.elnService.ElnCrossTemplateSnapshotResolver;
import jnpf.elnService.ElnTestRequestIdentityLookup;
import jnpf.elnService.ElnRecordSourceResolver;
import jnpf.exception.DataException;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;

import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Date;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.Set;

@Component
public class ElnCrossTemplateSnapshotResolverImpl implements ElnCrossTemplateSnapshotResolver {
    private final ElnTemplateCrossReferenceMapper referenceMapper;
    private final ElnRecordFieldValueMapper valueMapper;
    private final ElnTestRequestIdentityLookup identityLookup;
    private final ElnRecordSourceResolver sourceResolver;

    public ElnCrossTemplateSnapshotResolverImpl(ElnTemplateCrossReferenceMapper referenceMapper,
            ElnRecordFieldValueMapper valueMapper, ElnTestRequestIdentityLookup identityLookup,
            ElnRecordSourceResolver sourceResolver) {
        this.referenceMapper = referenceMapper;
        this.valueMapper = valueMapper;
        this.identityLookup = identityLookup;
        this.sourceResolver = sourceResolver;
    }

    @Override
    public Map<String, ElnRecordFieldValueEntity> resolve(String tenantId, String targetTestWorkItemId,
            List<ElnTemplateBindingEntity> targetBindings) {
        Map<String, ElnTemplateCrossReferenceEntity> rules = new LinkedHashMap<>();
        if (targetBindings == null || targetBindings.isEmpty()) return Collections.emptyMap();
        for (ElnTemplateBindingEntity binding : targetBindings) {
            if (binding == null || !StringUtils.hasText(binding.getId())) continue;
            ElnTemplateCrossReferenceEntity rule = rule(tenantId, binding.getId());
            if (rule != null) rules.put(binding.getId(), rule);
        }
        return resolveRules(tenantId, targetTestWorkItemId, rules);
    }

    @Override
    public Map<String, ElnRecordFieldValueEntity> resolveByBindingIds(String tenantId,
            String targetTestWorkItemId, Set<String> targetBindingIds) {
        if (targetBindingIds == null || targetBindingIds.isEmpty()) return Collections.emptyMap();
        Map<String, ElnTemplateCrossReferenceEntity> rules = new LinkedHashMap<>();
        for (String bindingId : targetBindingIds) {
            if (!StringUtils.hasText(bindingId)) continue;
            ElnTemplateCrossReferenceEntity rule = rule(tenantId, bindingId);
            if (rule != null) rules.put(bindingId, rule);
        }
        return resolveRules(tenantId, targetTestWorkItemId, rules);
    }

    @Override
    public List<SnapshotIssue> validatePersistedSnapshots(String tenantId,
            String targetTestWorkItemId, List<ElnRecordFieldValueEntity> targetValues) {
        List<ElnRecordFieldValueEntity> snapshots = crossTemplateValues(targetValues);
        if (snapshots.isEmpty()) return Collections.emptyList();

        Map<String, ElnTestRequestIdentityLookup.Identity> identities;
        try {
            identities = identityLookup.resolve(tenantId,
                    Collections.singletonList(targetTestWorkItemId));
        } catch (RuntimeException exception) {
            return issuesForAll(tenantId, snapshots, "SOURCE_RECORD_IDENTITY_INVALID",
                    message(exception, "目标检验项请验单身份解析失败"));
        }
        ElnTestRequestIdentityLookup.Identity target = identities == null
                ? null : identities.get(targetTestWorkItemId);
        if (target == null || !StringUtils.hasText(target.getTestRequestId())) {
            return issuesForAll(tenantId, snapshots, "SOURCE_RECORD_IDENTITY_INVALID",
                    "目标检验项缺少请验单身份");
        }

        List<SnapshotIssue> issues = new ArrayList<>();
        for (ElnRecordFieldValueEntity snapshot : snapshots) {
            validateSnapshot(tenantId, target.getTestRequestId(), snapshot, issues);
        }
        return issues;
    }

    private ElnTemplateCrossReferenceEntity rule(String tenantId, String bindingId) {
        return referenceMapper.selectOne(Wrappers.<ElnTemplateCrossReferenceEntity>lambdaQuery()
                .eq(ElnTemplateCrossReferenceEntity::getFTenantId, tenantId)
                .eq(ElnTemplateCrossReferenceEntity::getMubanBangdingId, bindingId)
                .eq(ElnTemplateCrossReferenceEntity::getFDeleteMark, 0));
    }

    private void validateSnapshot(String tenantId, String testRequestId,
            ElnRecordFieldValueEntity snapshot, List<SnapshotIssue> issues) {
        ElnTemplateCrossReferenceEntity rule = rule(tenantId, snapshot.getMubanBangdingId());
        if (rule == null) {
            issues.add(issue("CROSS_TEMPLATE_RULE_MISSING", "跨模板来源规则不存在",
                    snapshot, null));
            return;
        }
        try {
            ElnRecordEntity source = sourceResolver.resolve(
                    tenantId, testRequestId, rule.getLaiyuanMubanBianhao());
            if (!Objects.equals(snapshot.getKuamoLaiyuanJiluId(), source.getId())) {
                issues.add(issue("SOURCE_RECORD_DRIFT", "跨模板源记录已变化", snapshot, rule));
                return;
            }
            if (!Objects.equals(snapshot.getKuamoLaiyuanXiudingId(), source.getDangqianXiudingId())) {
                issues.add(issue("SOURCE_REVISION_DRIFT", "跨模板源记录当前修订已变化", snapshot, rule));
                return;
            }

            ElnRecordFieldValueEntity current = currentSourceValue(tenantId, source, rule);
            if (current == null || !hasValue(current)) {
                issues.add(issue("SOURCE_FIELD_VALUE_INVALID", "跨模板源字段值为空或不存在",
                        snapshot, rule));
                return;
            }
            if ("CROSS_TEMPLATE".equals(current.getZhiLaiyuan())) {
                issues.add(issue("SOURCE_FIELD_CHAIN_NOT_SUPPORTED", "跨模板源字段形成了间接引用链",
                        snapshot, rule));
                return;
            }
            if (!Objects.equals(snapshot.getKuamoLaiyuanZhiId(), current.getId())) {
                issues.add(issue("SOURCE_VALUE_ID_DRIFT", "跨模板源字段值身份已变化", snapshot, rule));
                return;
            }
            if (!Objects.equals(rule.getLaiyuanZiduanBanbenId(), current.getZiduanBanbenId())
                    || !Objects.equals(snapshot.getKuamoLaiyuanZiduanBanbenId(), current.getZiduanBanbenId())) {
                issues.add(issue("SOURCE_FIELD_VERSION_DRIFT", "跨模板源字段固定版本已变化",
                        snapshot, rule));
                return;
            }
            if (!sameValue(snapshot, current)) {
                issues.add(issue("SOURCE_VALUE_DRIFT", "跨模板源字段值已变化", snapshot, rule));
            }
        } catch (RuntimeException exception) {
            issues.add(issue(code(exception, "SOURCE_RECORD_INVALID"),
                    message(exception, "跨模板源记录当前不可用"), snapshot, rule));
        }
    }

    private ElnRecordFieldValueEntity currentSourceValue(String tenantId, ElnRecordEntity source,
            ElnTemplateCrossReferenceEntity rule) {
        return valueMapper.selectOne(Wrappers.<ElnRecordFieldValueEntity>lambdaQuery()
                .eq(ElnRecordFieldValueEntity::getFTenantId, tenantId)
                .eq(ElnRecordFieldValueEntity::getDianziJiluId, source.getId())
                .eq(ElnRecordFieldValueEntity::getXiudingId, source.getDangqianXiudingId())
                .eq(ElnRecordFieldValueEntity::getZiduanDingyiId, rule.getLaiyuanZiduanDingyiId())
                .eq(ElnRecordFieldValueEntity::getBangdingJuese, "PRIMARY")
                .eq(ElnRecordFieldValueEntity::getBangdingZhuangtai, "ACTIVE")
                .and(q -> q.isNull(ElnRecordFieldValueEntity::getFDeleteMark)
                        .or().eq(ElnRecordFieldValueEntity::getFDeleteMark, 0)));
    }

    private List<SnapshotIssue> issuesForAll(String tenantId,
            List<ElnRecordFieldValueEntity> snapshots,
            String code, String message) {
        List<SnapshotIssue> issues = new ArrayList<>();
        for (ElnRecordFieldValueEntity snapshot : snapshots) {
            ElnTemplateCrossReferenceEntity rule = rule(tenantId, snapshot.getMubanBangdingId());
            issues.add(issue(code, message, snapshot, rule));
        }
        return issues;
    }

    private static List<ElnRecordFieldValueEntity> crossTemplateValues(
            List<ElnRecordFieldValueEntity> values) {
        if (values == null || values.isEmpty()) return Collections.emptyList();
        List<ElnRecordFieldValueEntity> snapshots = new ArrayList<>();
        for (ElnRecordFieldValueEntity value : values) {
            if (value != null && "CROSS_TEMPLATE".equals(value.getZhiLaiyuan())) snapshots.add(value);
        }
        return snapshots;
    }

    private static SnapshotIssue issue(String code, String message,
            ElnRecordFieldValueEntity snapshot, ElnTemplateCrossReferenceEntity rule) {
        return new SnapshotIssue(code, message, snapshot.getMubanBangdingId(),
                snapshot.getZiduanBianma(), rule == null ? null : rule.getLaiyuanMubanBianhao());
    }

    private static boolean sameValue(ElnRecordFieldValueEntity snapshot,
            ElnRecordFieldValueEntity source) {
        return Objects.equals(snapshot.getZhiWenben(), source.getZhiWenben())
                && decimalEquals(snapshot.getZhiShuzhi(), source.getZhiShuzhi())
                && dateEquals(snapshot.getZhiRiqi(), source.getZhiRiqi());
    }

    private static boolean decimalEquals(BigDecimal left, BigDecimal right) {
        return left == null ? right == null : right != null && left.compareTo(right) == 0;
    }

    private static boolean dateEquals(Date left, Date right) {
        return left == null ? right == null : right != null && left.getTime() == right.getTime();
    }

    private static String code(RuntimeException exception, String fallback) {
        String value = exception == null ? null : exception.getMessage();
        if (!StringUtils.hasText(value)) return fallback;
        int separator = value.indexOf(':');
        String candidate = separator < 0 ? value : value.substring(0, separator);
        return candidate.matches("[A-Z][A-Z0-9_]*") ? candidate : fallback;
    }

    private static String message(RuntimeException exception, String fallback) {
        return exception != null && StringUtils.hasText(exception.getMessage())
                ? exception.getMessage() : fallback;
    }

    private Map<String, ElnRecordFieldValueEntity> resolveRules(String tenantId,
            String targetTestWorkItemId, Map<String, ElnTemplateCrossReferenceEntity> rules) {
        Map<String, ElnRecordFieldValueEntity> snapshots = new LinkedHashMap<>();
        if (rules.isEmpty()) return snapshots;
        Map<String, ElnTestRequestIdentityLookup.Identity> identities = identityLookup.resolve(
                tenantId, Collections.singletonList(targetTestWorkItemId));
        if (identities == null) identities = Collections.emptyMap();
        ElnTestRequestIdentityLookup.Identity target = identities.get(targetTestWorkItemId);
        if (target == null || !StringUtils.hasText(target.getTestRequestId())) {
            throw new DataException("SOURCE_RECORD_IDENTITY_INVALID: 目标检验项缺少请验单身份");
        }
        for (Map.Entry<String, ElnTemplateCrossReferenceEntity> entry : rules.entrySet()) {
            String bindingId = entry.getKey();
            ElnTemplateCrossReferenceEntity rule = entry.getValue();
            ElnRecordEntity source = sourceResolver.resolve(tenantId, target.getTestRequestId(), rule.getLaiyuanMubanBianhao());
            ElnRecordFieldValueEntity sourceValue = valueMapper.selectOne(
                    Wrappers.<ElnRecordFieldValueEntity>lambdaQuery().eq(ElnRecordFieldValueEntity::getFTenantId, tenantId)
                            .eq(ElnRecordFieldValueEntity::getDianziJiluId, source.getId())
                            .eq(ElnRecordFieldValueEntity::getXiudingId, source.getDangqianXiudingId())
                            .eq(ElnRecordFieldValueEntity::getZiduanDingyiId, rule.getLaiyuanZiduanDingyiId())
                            .eq(ElnRecordFieldValueEntity::getZiduanBanbenId, rule.getLaiyuanZiduanBanbenId())
                            .eq(ElnRecordFieldValueEntity::getBangdingJuese, "PRIMARY")
                            .eq(ElnRecordFieldValueEntity::getBangdingZhuangtai, "ACTIVE")
                            .and(q -> q.isNull(ElnRecordFieldValueEntity::getFDeleteMark)
                                    .or().eq(ElnRecordFieldValueEntity::getFDeleteMark, 0)));
            if (sourceValue == null || !hasValue(sourceValue)) {
                throw new DataException("SOURCE_FIELD_VALUE_INVALID: 源字段值为空或版本不符");
            }
            if ("CROSS_TEMPLATE".equals(sourceValue.getZhiLaiyuan())) {
                throw new DataException("SOURCE_FIELD_CHAIN_NOT_SUPPORTED: 源字段不能来自跨模板引用");
            }
            snapshots.put(bindingId, sourceValue);
        }
        return snapshots;
    }

    private static boolean hasValue(ElnRecordFieldValueEntity value) {
        return StringUtils.hasText(value.getZhiWenben())
                || value.getZhiShuzhi() != null || value.getZhiRiqi() != null;
    }
}