package jnpf.elnService.template;

import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import jnpf.audit.model.AuditEventDTO;
import jnpf.audit.sdk.AuditClient;
import jnpf.elnEntity.field.ElnFieldVersionEntity;
import jnpf.elnEntity.formula.ElnTemplateFormulaBindingEntity;
import jnpf.elnEntity.template.ElnTemplateBindingEntity;
import jnpf.elnEntity.template.ElnTemplateVos;
import jnpf.elnMapper.ElnFieldVersionMapper;
import jnpf.elnMapper.ElnTemplateFormulaBindingMapper;
import jnpf.elnMapper.ElnTemplateBindingMapper;
import jnpf.elnService.template.docx.DocxControlConfigMatcher;
import jnpf.elnService.template.docx.DocxExpectedControlConfig;
import jnpf.elnService.template.docx.DocxControlSnapshot;
import jnpf.exception.DataException;
import jnpf.util.JsonUtil;
import org.springframework.beans.factory.ObjectProvider;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;

import java.util.ArrayList;
import java.util.Date;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.function.Consumer;

@Service
public class ElnPendingBindingCleanupService {

    private static final String PENDING = "PENDING";
    private static final String CANCELLED = "CANCELLED";
    private static final String TIMEOUT_REASON = "PENDING_TIMEOUT_NO_CONTROL";
    private static final String FORMULA_TIMEOUT_REASON = "PENDING_TIMEOUT_NO_LOCK";

    private final Store store;
    private final FormulaStore formulaStore;
    private final Consumer<AuditEventDTO> auditRecorder;

    @Autowired
    public ElnPendingBindingCleanupService(ElnTemplateBindingMapper bindingMapper,
            ElnFieldVersionMapper fieldVersionMapper,
            ElnTemplateFormulaBindingMapper formulaBindingMapper,
            ObjectProvider<AuditClient> auditClientProvider) {
        this(new MyBatisStore(bindingMapper, fieldVersionMapper),
                new MyBatisFormulaStore(formulaBindingMapper, bindingMapper), event -> {
            AuditClient client = auditClientProvider.getIfAvailable();
            if (client != null) {
                client.record(event);
            }
        });
    }

    ElnPendingBindingCleanupService(Store store, Consumer<AuditEventDTO> auditRecorder) {
        this(store, FormulaStore.none(), auditRecorder);
    }

    ElnPendingBindingCleanupService(Store store, FormulaStore formulaStore,
            Consumer<AuditEventDTO> auditRecorder) {
        this.store = store;
        this.formulaStore = formulaStore == null ? FormulaStore.none() : formulaStore;
        this.auditRecorder = auditRecorder;
    }

    public List<ElnTemplateVos.Diagnostic> reconcileExpired(String tenantId, String templateId,
            Date now, List<DocxControlSnapshot> controls) {
        if (!StringUtils.hasText(tenantId) || !StringUtils.hasText(templateId)
                || now == null || controls == null) {
            throw new DataException("PENDING 绑定对账参数无效");
        }
        Map<String, List<DocxControlSnapshot>> byTag = new LinkedHashMap<>();
        for (DocxControlSnapshot control : controls) {
            if (control != null && StringUtils.hasText(control.getTag())) {
                byTag.computeIfAbsent(control.getTag(), key -> new ArrayList<>()).add(control);
            }
        }
        List<ElnTemplateVos.Diagnostic> result = new ArrayList<>();
        for (ElnTemplateBindingEntity binding
                : store.listExpired(tenantId.trim(), templateId.trim(), now)) {
            if (binding == null || !tenantId.trim().equals(binding.getFTenantId())
                    || !templateId.trim().equals(binding.getMubanId())
                    || !PENDING.equals(binding.getBangdingZhuangtai())
                    || binding.getDaoqiShijian() == null
                    || !binding.getDaoqiShijian().before(now)) {
                continue;
            }
            List<DocxControlSnapshot> matches = byTag.get(binding.getKongjianBiaoqian());
            int count = matches == null ? 0 : matches.size();
            if (count == 0) {
                if (binding.getFVersion() != null && store.cancelIfPending(
                        binding, binding.getFVersion(), now, TIMEOUT_REASON)) {
                    result.add(diagnostic("INFO", TIMEOUT_REASON, binding,
                            "超时待确认绑定未在 DOCX 中产生控件，已取消"));
                    auditCancellation(binding);
                }
                continue;
            }
            if (count > 1) {
                result.add(diagnostic("ERROR", "DUPLICATE_TAG", binding,
                        "待确认控件 Tag 在 DOCX 中出现多次"));
                continue;
            }
            DocxControlSnapshot control = matches.get(0);
            if (!Objects.equals(binding.getKongjianJuese(), control.getControlRole())) {
                result.add(diagnostic("ERROR", "ROLE_MISMATCH", binding,
                        "待确认控件角色与预留绑定不一致"));
            } else if (!Objects.equals(binding.getKongjianLeixing(), control.getControlType())) {
                result.add(diagnostic("ERROR", "TYPE_MISMATCH", binding,
                        "待确认控件类型与预留绑定不一致"));
            } else if (!DocxControlConfigMatcher.matches(binding.getKongjianLeixing(),
                    store.expectedControlConfig(tenantId, binding),
                    control.getControlConfig())) {
                result.add(diagnostic("ERROR", "CONFIG_MISMATCH", binding,
                        "待确认控件配置与字段版本不一致"));
            } else {
                result.add(diagnostic("WARNING", "PENDING_CONFIRMATION_REQUIRED", binding,
                        "DOCX 已存在控件，请插件按原操作码完成确认"));
            }
        }
        reconcileExpiredFormulaBindings(tenantId.trim(), templateId.trim(), now, byTag, result);
        return result;
    }

    private void reconcileExpiredFormulaBindings(String tenantId, String templateId, Date now,
            Map<String, List<DocxControlSnapshot>> controlsByTag,
            List<ElnTemplateVos.Diagnostic> diagnostics) {
        for (ElnTemplateFormulaBindingEntity formula
                : formulaStore.listExpired(tenantId, templateId, now)) {
            if (formula == null || !tenantId.equals(formula.getFTenantId())
                    || !templateId.equals(formula.getMubanId())
                    || !PENDING.equals(formula.getBangdingZhuangtai())
                    || formula.getDaoqiShijian() == null
                    || !formula.getDaoqiShijian().before(now)) continue;
            List<ElnTemplateBindingEntity> resultControls = formulaStore.resultControls(
                    tenantId, templateId, formula.getId());
            ElnTemplateBindingEntity primary = null;
            for (ElnTemplateBindingEntity field : safe(resultControls)) {
                if (formula.getJieguoBangdingId().equals(field.getId())
                        && "PRIMARY".equals(field.getKongjianJuese())) primary = field;
            }
            List<DocxControlSnapshot> primaryMatches = primary == null ? null
                    : controlsByTag.get(primary.getKongjianBiaoqian());
            if (primary == null || primaryMatches == null || primaryMatches.size() != 1) {
                diagnostics.add(formulaDiagnostic("ERROR", "FORMULA_RESULT_LOCK_MISMATCH",
                        formula, "公式结果主控件锁状态不完整"));
                continue;
            }
            DocxControlSnapshot primaryControl = primaryMatches.get(0);
            if (!StringUtils.hasText(primaryControl.getLock())) {
                boolean allEditable = true;
                for (ElnTemplateBindingEntity field : safe(resultControls)) {
                    List<DocxControlSnapshot> matches = controlsByTag.get(field.getKongjianBiaoqian());
                    allEditable &= matches != null && matches.size() == 1
                            && !StringUtils.hasText(matches.get(0).getLock());
                }
                if (allEditable) {
                    ElnTemplateFormulaBindingEntity before = copyFormulaBinding(formula);
                    if (formula.getFVersion() != null && formulaStore.cancelIfPending(
                            formula, formula.getFVersion(), now, FORMULA_TIMEOUT_REASON)) {
                        diagnostics.add(formulaDiagnostic("INFO", FORMULA_TIMEOUT_REASON, formula,
                                "公式结果主控件仍可编辑，超时映射已取消"));
                        auditFormulaCancellation(before);
                    }
                } else {
                    diagnostics.add(formulaDiagnostic("ERROR", "FORMULA_RESULT_LOCK_MISMATCH",
                            formula, "公式结果控件锁状态不完整"));
                }
                continue;
            }
            boolean completeReadOnly = "sdtContentLocked".equals(primaryControl.getLock());
            for (ElnTemplateBindingEntity field : safe(resultControls)) {
                List<DocxControlSnapshot> matches = controlsByTag.get(field.getKongjianBiaoqian());
                completeReadOnly &= matches != null && matches.size() == 1
                        && "sdtContentLocked".equals(matches.get(0).getLock());
            }
            diagnostics.add(formulaDiagnostic(completeReadOnly ? "WARNING" : "ERROR",
                    completeReadOnly ? "PENDING_CONFIRMATION_REQUIRED"
                            : "FORMULA_RESULT_LOCK_MISMATCH",
                    formula, completeReadOnly ? "公式结果控件已只读，请插件继续确认"
                            : "公式结果控件锁状态不完整"));
        }
    }

    private static <T> List<T> safe(List<T> values) {
        return values == null ? java.util.Collections.emptyList() : values;
    }

    private void auditFormulaCancellation(ElnTemplateFormulaBindingEntity before) {
        ElnTemplateFormulaBindingEntity after = copyFormulaBinding(before);
        after.setBangdingZhuangtai(CANCELLED);
        after.setZhuangtaiYuanyin(FORMULA_TIMEOUT_REASON);
        if (after.getFVersion() != null) after.setFVersion(after.getFVersion() + 1);
        Map<String, Object> snapshot = new LinkedHashMap<>();
        snapshot.put("templateId", before.getMubanId());
        snapshot.put("formulaDefinitionId", before.getGongshiDingyiId());
        snapshot.put("formulaVersionId", before.getGongshiBanbenId());
        snapshot.put("parameterBindings", before.getCanshuYingshe());
        snapshot.put("resultBindingId", before.getJieguoBangdingId());
        snapshot.put("operationCode", before.getCaozuoBianma());
        snapshot.put("reason", FORMULA_TIMEOUT_REASON);
        snapshot.put("before", before);
        snapshot.put("after", after);
        snapshot.put("beforeStatus", PENDING);
        snapshot.put("afterStatus", CANCELLED);
        auditRecorder.accept(AuditEventDTO.builder().tenantId(before.getFTenantId())
                .eventTime(new Date()).eventType("DATA_CHANGE")
                .actionCode("ELN_TEMPLATE_FORMULA_CANCEL")
                .actionLabel("取消超时待确认模板公式映射")
                .bizModule("eln").bizType("eln_template_formula_binding")
                .targetTable("eln_template_formula_binding").targetId(before.getId())
                .reason(FORMULA_TIMEOUT_REASON)
                .dataSnapshot(JsonUtil.getObjectToString(snapshot)).build());
    }

    private static ElnTemplateFormulaBindingEntity copyFormulaBinding(
            ElnTemplateFormulaBindingEntity binding) {
        return JsonUtil.getJsonToBean(JsonUtil.getObjectToString(binding),
                ElnTemplateFormulaBindingEntity.class);
    }

    private static ElnTemplateVos.Diagnostic formulaDiagnostic(String severity, String code,
            ElnTemplateFormulaBindingEntity binding, String message) {
        ElnTemplateVos.Diagnostic result = new ElnTemplateVos.Diagnostic();
        result.setSeverity(severity); result.setCode(code); result.setMessage(message);
        result.setBindingId(binding.getId());
        return result;
    }

    private void auditCancellation(ElnTemplateBindingEntity binding) {
        Map<String, Object> snapshot = new LinkedHashMap<>();
        snapshot.put("templateId", binding.getMubanId());
        snapshot.put("bindingId", binding.getId());
        snapshot.put("reason", TIMEOUT_REASON);
        snapshot.put("beforeStatus", PENDING);
        snapshot.put("afterStatus", CANCELLED);
        auditRecorder.accept(AuditEventDTO.builder()
                .tenantId(binding.getFTenantId())
                .eventTime(new Date())
                .eventType("DATA_CHANGE")
                .actionCode("ELN_TEMPLATE_BINDING_CANCEL")
                .actionLabel("取消超时待确认模板绑定")
                .bizModule("eln")
                .bizType("eln_template_binding")
                .targetTable("eln_template_binding")
                .targetId(binding.getId())
                .reason(TIMEOUT_REASON)
                .dataSnapshot(JsonUtil.getObjectToString(snapshot))
                .build());
    }

    private static ElnTemplateVos.Diagnostic diagnostic(String severity, String code,
            ElnTemplateBindingEntity binding, String message) {
        ElnTemplateVos.Diagnostic result = new ElnTemplateVos.Diagnostic();
        result.setSeverity(severity);
        result.setCode(code);
        result.setMessage(message);
        result.setBindingId(binding.getId());
        result.setControlTag(binding.getKongjianBiaoqian());
        return result;
    }

    public interface Store {
        List<ElnTemplateBindingEntity> listExpired(
                String tenantId, String templateId, Date now);

        Map<String, Object> expectedControlConfig(
                String tenantId, ElnTemplateBindingEntity binding);

        boolean cancelIfPending(ElnTemplateBindingEntity binding, int expectedVersion,
                Date now, String reason);
    }

    public interface FormulaStore {
        List<ElnTemplateFormulaBindingEntity> listExpired(
                String tenantId, String templateId, Date now);
        List<ElnTemplateBindingEntity> resultControls(
                String tenantId, String templateId, String formulaBindingId);
        boolean cancelIfPending(ElnTemplateFormulaBindingEntity binding,
                int expectedVersion, Date now, String reason);
        static FormulaStore none() {
            return new FormulaStore() {
                @Override public List<ElnTemplateFormulaBindingEntity> listExpired(
                        String tenantId, String templateId, Date now) {
                    return java.util.Collections.emptyList();
                }
                @Override public List<ElnTemplateBindingEntity> resultControls(
                        String tenantId, String templateId, String formulaBindingId) {
                    return java.util.Collections.emptyList();
                }
                @Override public boolean cancelIfPending(ElnTemplateFormulaBindingEntity binding,
                        int expectedVersion, Date now, String reason) { return false; }
            };
        }
    }

    private static final class MyBatisStore implements Store {
        private final ElnTemplateBindingMapper bindingMapper;
        private final ElnFieldVersionMapper fieldVersionMapper;

        private MyBatisStore(ElnTemplateBindingMapper bindingMapper,
                ElnFieldVersionMapper fieldVersionMapper) {
            this.bindingMapper = bindingMapper;
            this.fieldVersionMapper = fieldVersionMapper;
        }

        @Override
        public List<ElnTemplateBindingEntity> listExpired(
                String tenantId, String templateId, Date now) {
            return bindingMapper.selectList(Wrappers.<ElnTemplateBindingEntity>lambdaQuery()
                    .eq(ElnTemplateBindingEntity::getFTenantId, tenantId)
                    .eq(ElnTemplateBindingEntity::getMubanId, templateId)
                    .eq(ElnTemplateBindingEntity::getBangdingZhuangtai, PENDING)
                    .isNotNull(ElnTemplateBindingEntity::getDaoqiShijian)
                    .lt(ElnTemplateBindingEntity::getDaoqiShijian, now)
                    .and(q -> q.isNull(ElnTemplateBindingEntity::getFDeleteMark)
                            .or().eq(ElnTemplateBindingEntity::getFDeleteMark, 0))
                    .orderByAsc(ElnTemplateBindingEntity::getId));
        }

        @Override
        public Map<String, Object> expectedControlConfig(
                String tenantId, ElnTemplateBindingEntity binding) {
            ElnFieldVersionEntity version = fieldVersionMapper.selectOne(
                    Wrappers.<ElnFieldVersionEntity>lambdaQuery()
                            .eq(ElnFieldVersionEntity::getFTenantId, tenantId)
                            .eq(ElnFieldVersionEntity::getId, binding.getZiduanBanbenId())
                            .and(q -> q.isNull(ElnFieldVersionEntity::getFDeleteMark)
                                    .or().eq(ElnFieldVersionEntity::getFDeleteMark, 0)));
            if (version == null
                    || !Objects.equals(binding.getZiduanDingyiId(), version.getZiduanDingyiId())) {
                throw new DataException("待确认绑定的字段版本不存在或不属于当前租户");
            }
            return DocxExpectedControlConfig.from(
                    version.getShujuLeixing(), version.getKongjianPeizhi());
        }

        @Override
        public boolean cancelIfPending(ElnTemplateBindingEntity binding, int expectedVersion,
                Date now, String reason) {
            return bindingMapper.update(null,
                    Wrappers.<ElnTemplateBindingEntity>lambdaUpdate()
                            .eq(ElnTemplateBindingEntity::getFTenantId, binding.getFTenantId())
                            .eq(ElnTemplateBindingEntity::getMubanId, binding.getMubanId())
                            .eq(ElnTemplateBindingEntity::getId, binding.getId())
                            .eq(ElnTemplateBindingEntity::getFVersion, expectedVersion)
                            .eq(ElnTemplateBindingEntity::getBangdingZhuangtai, PENDING)
                            .isNotNull(ElnTemplateBindingEntity::getDaoqiShijian)
                            .lt(ElnTemplateBindingEntity::getDaoqiShijian, now)
                            .and(q -> q.isNull(ElnTemplateBindingEntity::getFDeleteMark)
                                    .or().eq(ElnTemplateBindingEntity::getFDeleteMark, 0))
                            .set(ElnTemplateBindingEntity::getBangdingZhuangtai, CANCELLED)
                            .set(ElnTemplateBindingEntity::getZhuangtaiYuanyin, reason)
                            .set(ElnTemplateBindingEntity::getFVersion, expectedVersion + 1)) == 1;
        }
    }

    private static final class MyBatisFormulaStore implements FormulaStore {
        private final ElnTemplateFormulaBindingMapper formulaMapper;
        private final ElnTemplateBindingMapper fieldMapper;
        private MyBatisFormulaStore(ElnTemplateFormulaBindingMapper formulaMapper,
                ElnTemplateBindingMapper fieldMapper) {
            this.formulaMapper = formulaMapper; this.fieldMapper = fieldMapper;
        }
        @Override public List<ElnTemplateFormulaBindingEntity> listExpired(
                String tenantId, String templateId, Date now) {
            return formulaMapper.selectList(Wrappers.<ElnTemplateFormulaBindingEntity>lambdaQuery()
                    .eq(ElnTemplateFormulaBindingEntity::getFTenantId, tenantId)
                    .eq(ElnTemplateFormulaBindingEntity::getMubanId, templateId)
                    .eq(ElnTemplateFormulaBindingEntity::getBangdingZhuangtai, PENDING)
                    .isNotNull(ElnTemplateFormulaBindingEntity::getDaoqiShijian)
                    .lt(ElnTemplateFormulaBindingEntity::getDaoqiShijian, now)
                    .and(q -> q.isNull(ElnTemplateFormulaBindingEntity::getFDeleteMark)
                            .or().eq(ElnTemplateFormulaBindingEntity::getFDeleteMark, 0)));
        }
        @Override public List<ElnTemplateBindingEntity> resultControls(
                String tenantId, String templateId, String formulaBindingId) {
            ElnTemplateFormulaBindingEntity formula = formulaMapper.selectOne(
                    Wrappers.<ElnTemplateFormulaBindingEntity>lambdaQuery()
                            .eq(ElnTemplateFormulaBindingEntity::getFTenantId, tenantId)
                            .eq(ElnTemplateFormulaBindingEntity::getMubanId, templateId)
                            .eq(ElnTemplateFormulaBindingEntity::getId, formulaBindingId));
            if (formula == null) return java.util.Collections.emptyList();
            return fieldMapper.selectList(Wrappers.<ElnTemplateBindingEntity>lambdaQuery()
                    .eq(ElnTemplateBindingEntity::getFTenantId, tenantId)
                    .eq(ElnTemplateBindingEntity::getMubanId, templateId)
                    .eq(ElnTemplateBindingEntity::getBangdingZhuangtai, "ACTIVE")
                    .and(q -> q.eq(ElnTemplateBindingEntity::getId, formula.getJieguoBangdingId())
                            .or().eq(ElnTemplateBindingEntity::getYinyongShiliId,
                                    formula.getJieguoBangdingId()))
                    .and(q -> q.isNull(ElnTemplateBindingEntity::getFDeleteMark)
                            .or().eq(ElnTemplateBindingEntity::getFDeleteMark, 0)));
        }
        @Override public boolean cancelIfPending(ElnTemplateFormulaBindingEntity binding,
                int expectedVersion, Date now, String reason) {
            return formulaMapper.update(null,
                    Wrappers.<ElnTemplateFormulaBindingEntity>lambdaUpdate()
                            .eq(ElnTemplateFormulaBindingEntity::getFTenantId, binding.getFTenantId())
                            .eq(ElnTemplateFormulaBindingEntity::getMubanId, binding.getMubanId())
                            .eq(ElnTemplateFormulaBindingEntity::getId, binding.getId())
                            .eq(ElnTemplateFormulaBindingEntity::getFVersion, expectedVersion)
                            .eq(ElnTemplateFormulaBindingEntity::getBangdingZhuangtai, PENDING)
                            .isNotNull(ElnTemplateFormulaBindingEntity::getDaoqiShijian)
                            .lt(ElnTemplateFormulaBindingEntity::getDaoqiShijian, now)
                            .and(q -> q.isNull(ElnTemplateFormulaBindingEntity::getFDeleteMark)
                                    .or().eq(ElnTemplateFormulaBindingEntity::getFDeleteMark, 0))
                            .set(ElnTemplateFormulaBindingEntity::getBangdingZhuangtai, CANCELLED)
                            .set(ElnTemplateFormulaBindingEntity::getZhuangtaiYuanyin, reason)
                            .set(ElnTemplateFormulaBindingEntity::getFVersion, expectedVersion + 1)) == 1;
        }
    }
}