package jnpf.elnService.formula.impl;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import jnpf.audit.model.AuditEventDTO;
import jnpf.elnEntity.formula.ElnFormulaDefEntity;
import jnpf.elnEntity.formula.ElnFormulaForms;
import jnpf.elnEntity.formula.ElnFormulaParameterSlotEntity;
import jnpf.elnEntity.formula.ElnFormulaVersionEntity;
import jnpf.elnEntity.formula.ElnFormulaVos;
import jnpf.elnEntity.formula.ElnTemplateFormulaBindingEntity;
import jnpf.elnEntity.template.ElnTemplateVersionEntity;
import jnpf.elnService.formula.ElnFormulaCatalogService;
import jnpf.elnService.impl.ElnFieldCodeGenerator;
import jnpf.exception.DataException;
import org.junit.Test;
import org.springframework.dao.DuplicateKeyException;
import org.springframework.transaction.support.TransactionSynchronizationManager;

import java.lang.reflect.Method;
import java.lang.reflect.Field;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.Comparator;
import java.util.LinkedHashMap;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.Supplier;

import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNotEquals;
import static org.junit.Assert.assertNull;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;

public class ElnFormulaCatalogServiceImplTest {

    @Test
    public void createsFormulaWithGeneratedCodeVersionOneSlotsAndAudit() {
        Fixture fixture = new Fixture();

        ElnFormulaVos.Detail detail = fixture.service.create(formula("含量计算", "${样品质量}",
                parameter("样品质量", "DECIMAL")));

        assertTrue(detail.getGongshiBianma().matches("hanliang_jisuan_[a-z0-9]{8}"));
        assertEquals("enabled", detail.getBizEnabled());
        assertNull(detail.getDangqianGongshiBanbenId());
        assertEquals(1, detail.getVersions().size());
        ElnFormulaVos.Version version = detail.getVersions().get(0);
        assertEquals(Integer.valueOf(1), version.getBanbenHao());
        assertEquals("DRAFT", version.getBizStatus());
        assertTrue(version.getParameters().get(0).getCanshuBianma()
                .matches("yang_pin_zhi_liang_[a-z0-9]{8}"));
        assertEquals(Arrays.asList("ELN_FORMULA_CREATE", "ELN_FORMULA_VERSION_CREATE"),
                fixture.auditActions());
    }

    @Test
    public void createsFormulaCodesWithWordLevelPinyinForDomainAndMixedNames() {
        Fixture fixture = new Fixture();

        ElnFormulaVos.Detail domain = fixture.service.create(formula("有关物质计算", "1"));
        ElnFormulaVos.Detail mixed = fixture.service.create(formula("HPLC含量计算", "1"));

        assertTrue(domain.getGongshiBianma().matches("youguan_wuzhi_jisuan_[a-z0-9]{8}"));
        assertTrue(mixed.getGongshiBianma().matches("hplc_hanliang_jisuan_[a-z0-9]{8}"));
    }

    @Test
    public void createsDraftWithStableParameterCodesAndRejectsEmptyExpressionAtPreRelease() {
        Fixture fixture = new Fixture();
        ElnFormulaForms.CreateDraft draft = new ElnFormulaForms.CreateDraft();
        draft.setGongshiMingcheng("含量计算草稿");
        draft.setParameters(Arrays.asList(parameter("样品质量", "DECIMAL"), parameter("稀释倍数", "DECIMAL")));

        ElnFormulaVos.Detail detail = fixture.service.createDraft(draft);

        ElnFormulaVos.Version version = detail.getVersions().get(0);
        assertEquals("DRAFT", version.getBizStatus());
        assertEquals("", version.getBiaodashi());
        assertEquals("DECIMAL", version.getJieguoLeixing());
        assertNull(version.getXiuyueMoshi());
        assertNull(version.getXiuyueXiaoshuWei());
        assertEquals(2, version.getParameters().size());
        assertTrue(version.getParameters().get(0).getCanshuBianma().matches("yang_pin_zhi_liang_[a-z0-9]{8}"));
        assertTrue(version.getParameters().get(1).getCanshuBianma().matches("xi_shi_bei_shu_[a-z0-9]{8}"));
        assertNotEquals(version.getParameters().get(0).getCanshuBianma(), version.getParameters().get(1).getCanshuBianma());
        assertEquals(Arrays.asList("ELN_FORMULA_CREATE", "ELN_FORMULA_VERSION_CREATE"), fixture.auditActions());

        expectDataException(() -> fixture.service.preRelease(version.getId()));
        assertEquals("DRAFT", fixture.service.detail(detail.getId()).getVersions().get(0).getBizStatus());
    }

    @Test
    public void updatesAuditableDefinitionWithoutChangingCode() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail created = fixture.service.create(formula("原名称", "1"));
        ElnFormulaForms.UpdateDefinition update = new ElnFormulaForms.UpdateDefinition();
        update.setGongshiMingcheng("新名称");
        update.setYewuYongtu("用于复核");
        update.setBeizhu("变更说明");

        ElnFormulaVos.Detail updated = fixture.service.updateDefinition(created.getId(), update);

        assertEquals(created.getGongshiBianma(), updated.getGongshiBianma());
        assertEquals("新名称", updated.getGongshiMingcheng());
        assertEquals("用于复核", updated.getYewuYongtu());
        assertEquals("ELN_FORMULA_UPDATE", fixture.auditActions().get(2));
        assertTrue(fixture.audits.get(2).getDataSnapshot().contains("原名称"));
        assertTrue(fixture.audits.get(2).getDataSnapshot().contains("新名称"));
    }

    @Test
    public void copiesSlotCodesAndDraftEditOnlyDeletesCurrentVersionSlots() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail created = fixture.service.create(formula("含量", "1",
                parameter("质量", "DECIMAL"), parameter("体积", "DECIMAL")));
        ElnFormulaVos.Version v1 = created.getVersions().get(0);
        fixture.service.preRelease(v1.getId());
        fixture.service.publish(v1.getId());

        ElnFormulaVos.Version v2 = fixture.service.createVersion(created.getId(), copyOf(v1.getId()));
        ElnFormulaForms.Parameter kept = parameterFrom(v2.getParameters().get(0));
        ElnFormulaForms.Parameter added = parameter("稀释倍数", "DECIMAL");
        ElnFormulaForms.UpdateVersion update = version("${" + keptCode(v2, 0) + "}", kept, added);
        ElnFormulaVos.Version updated = fixture.service.updateDraft(v2.getId(), update);

        assertEquals(v1.getParameters().get(0).getCanshuBianma(),
                updated.getParameters().get(0).getCanshuBianma());
        assertTrue(updated.getParameters().get(1).getCanshuBianma()
                .matches("xi_shi_bei_shu_[a-z0-9]{8}"));
        assertEquals(2, fixture.service.detail(created.getId()).getVersions().get(0)
                .getParameters().size());
        assertEquals(2, updated.getParameters().size());
        assertNotEquals(v1.getParameters().get(1).getId(), updated.getParameters().get(1).getId());
    }

    @Test
    public void neverReusesCancelledVersionNumberAndPublishedContentIsImmutable() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail created = fixture.service.create(formula("平均值", "1"));
        String v1 = created.getVersions().get(0).getId();
        fixture.service.preRelease(v1);
        fixture.service.publish(v1);
        ElnFormulaVos.Version v2 = fixture.service.createVersion(created.getId(), copyOf(v1));
        fixture.service.cancel(v2.getId(), "不再使用");
        ElnFormulaVos.Version v3 = fixture.service.createVersion(created.getId(), copyOf(v1));

        assertEquals(Integer.valueOf(2), v2.getBanbenHao());
        assertEquals(Integer.valueOf(3), v3.getBanbenHao());
        expectDataException(() -> fixture.service.updateDraft(v1, version("2")));
    }

    @Test
    public void followsLifecyclePublishesCurrentAndSwitchesOnlySamePublishedFormula() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail first = fixture.service.create(formula("公式一", "1"));
        String v1 = first.getVersions().get(0).getId();
        ElnFormulaVos.Detail other = fixture.service.create(formula("公式二", "2"));
        String otherV1 = other.getVersions().get(0).getId();

        expectDataException(() -> fixture.service.publish(v1));
        fixture.service.preRelease(v1);
        expectDataException(() -> fixture.service.updateDraft(v1, version("3")));
        fixture.service.publish(v1);
        assertEquals(v1, fixture.service.detail(first.getId()).getDangqianGongshiBanbenId());
        expectDataException(() -> fixture.service.switchCurrent(first.getId(), otherV1, "错误切换"));
        expectDataException(() -> fixture.service.switchCurrent(other.getId(), otherV1, "尚未发布"));
    }

    @Test
    public void blocksCancellingReferencedPreReleaseVersion() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail created = fixture.service.create(formula("引用公式", "1"));
        String versionId = created.getVersions().get(0).getId();
        fixture.service.preRelease(versionId);
        fixture.hasDraftReference = true;

        expectDataException(() -> fixture.service.cancel(versionId, "尝试作废"));

        assertEquals("PRE_RELEASE", fixture.service.detail(created.getId())
                .getVersions().get(0).getBizStatus());
    }

    @Test
    public void blocksCancellingPreReleaseWhenReferenceCheckerIsUnavailable() {
        Fixture fixture = new Fixture(false, new String[0]);
        ElnFormulaVos.Detail created = fixture.service.create(formula("引用检查不可用", "1"));
        String versionId = created.getVersions().get(0).getId();
        fixture.service.preRelease(versionId);

        expectDataException("引用检查能力不可用",
                () -> fixture.service.cancel(versionId, "尝试作废"));

        assertEquals("PRE_RELEASE", fixture.service.detail(created.getId())
                .getVersions().get(0).getBizStatus());
    }

    @Test
    public void allowsCancellingPreReleaseWhenCheckerConfirmsNoDraftReference() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail created = fixture.service.create(formula("无引用公式", "1"));
        String versionId = created.getVersions().get(0).getId();
        fixture.service.preRelease(versionId);

        fixture.service.cancel(versionId, "确认无引用后作废");

        assertEquals("CANCELLED", fixture.service.detail(created.getId())
                .getVersions().get(0).getBizStatus());
    }

    @Test
    public void preReleaseReloadsStoredVersionAndSlotsForValidation() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail created = fixture.service.create(formula("数据库校验", "1",
                parameter("质量", "DECIMAL")));
        String versionId = created.getVersions().get(0).getId();
        fixture.store.versions.get(versionId).setBiaodashi("${unknown_a1}");

        expectDataException(() -> fixture.service.preRelease(versionId));

        assertEquals("DRAFT", fixture.store.versions.get(versionId).getBizStatus());
    }

    @Test
    public void rejectsCancelReasonLongerThanDatabaseColumn() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail created = fixture.service.create(formula("原因长度", "1"));
        String versionId = created.getVersions().get(0).getId();
        fixture.service.preRelease(versionId);

        expectDataException(() -> fixture.service.cancel(versionId, repeat("原", 501)));

        assertEquals("PRE_RELEASE", fixture.service.detail(created.getId())
                .getVersions().get(0).getBizStatus());
    }

    @Test
    public void generatesBoundedValidCodesAndRetriesFormulaAndParameterCollisions() {
        Fixture fixture = new Fixture("same0001", "same0001", "next0002",
                "slot0001", "slot0001", "slot0002");
        fixture.service.create(formula("同名", "1"));
        ElnFormulaVos.Detail second = fixture.service.create(formula("同名", "${参数}",
                parameter("参数", "DECIMAL"), parameter("参数", "DECIMAL")));
        ElnFormulaVos.Detail longName = fixture.service.create(formula(repeat("超长公式", 20), "1"));
        ElnFormulaVos.Detail numeric = fixture.service.create(formula("123公式", "1"));
        ElnFormulaVos.Detail fallback = fixture.service.create(formula("***", "1"));

        assertTrue(second.getGongshiBianma().endsWith("next0002"));
        assertTrue(longName.getGongshiBianma().length() <= 80);
        assertTrue(numeric.getGongshiBianma().startsWith("f_123_gongshi_"));
        assertTrue(fallback.getGongshiBianma().startsWith("formula_"));
        for (ElnFormulaVos.Parameter parameter : second.getVersions().get(0).getParameters()) {
            assertTrue(parameter.getCanshuBianma().length() <= 80);
            assertTrue(parameter.getCanshuBianma().matches("[a-z][a-z0-9_]*"));
        }
        assertNotEquals(second.getVersions().get(0).getParameters().get(0).getCanshuBianma(),
                second.getVersions().get(0).getParameters().get(1).getCanshuBianma());

        ElnFormulaVos.Detail parameterEdges = fixture.service.create(formula("参数边界", "1",
                parameter(repeat("超长参数", 20), "DECIMAL"),
                parameter("123参数", "DECIMAL"), parameter("***", "DECIMAL")));
        List<ElnFormulaVos.Parameter> edgeParameters = parameterEdges.getVersions().get(0)
                .getParameters();
        assertTrue(edgeParameters.get(0).getCanshuBianma().length() <= 80);
        assertTrue(edgeParameters.get(1).getCanshuBianma().startsWith("p_123_can_shu_"));
        assertTrue(edgeParameters.get(2).getCanshuBianma().startsWith("parameter_"));
        for (ElnFormulaVos.Parameter parameter : edgeParameters) {
            assertTrue(parameter.getCanshuBianma().matches("[a-z][a-z0-9_]*"));
        }
    }

    @Test
    public void activeTransactionDelegatesAuditsImmediatelyWithoutRegisteringSynchronization() {
        Fixture fixture = new Fixture();
        TransactionSynchronizationManager.setActualTransactionActive(true);
        TransactionSynchronizationManager.initSynchronization();
        try {
            fixture.service.create(formula("回滚公式", "1"));
            assertEquals(Arrays.asList("ELN_FORMULA_CREATE", "ELN_FORMULA_VERSION_CREATE"),
                    fixture.auditActions());
            assertTrue(TransactionSynchronizationManager.getSynchronizations().isEmpty());
        } finally {
            TransactionSynchronizationManager.clearSynchronization();
            TransactionSynchronizationManager.setActualTransactionActive(false);
        }
    }

    @Test
    public void catalogContractHasNoDeleteMethod() {
        for (Method method : ElnFormulaCatalogService.class.getMethods()) {
            assertFalse("delete".equals(method.getName()));
        }
    }

    @Test
    public void pageCountsOnlyPendingAndActiveTemplateFormulaBindings() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail formula = fixture.service.create(formula("引用统计", "1"));
        fixture.store.addFormulaBinding(binding("binding-active", "tenant-1", "template-1",
                formula.getId(), "version-1", "ACTIVE"));
        fixture.store.addFormulaBinding(binding("binding-pending", "tenant-1", "template-2",
                formula.getId(), "version-2", "PENDING"));
        fixture.store.addFormulaBinding(binding("binding-cancelled", "tenant-1", "template-3",
                formula.getId(), "version-3", "CANCELLED"));
        fixture.store.addFormulaBinding(binding("binding-removed", "tenant-1", "template-4",
                formula.getId(), "version-4", "REMOVED"));
        fixture.store.addFormulaBinding(binding("binding-foreign", "tenant-2", "template-5",
                formula.getId(), "version-5", "ACTIVE"));

        ElnFormulaVos.ListItem item = fixture.service.page(query()).getRecords().get(0);

        assertEquals(Integer.valueOf(2), property(item, "mubanYinyongShu"));
    }

    @Test
    public void pagePrefetchesVersionSummariesWithoutPerFormulaQueries() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail first = fixture.service.create(formula("批量公式一", "1"));
        ElnFormulaVos.Detail second = fixture.service.create(formula("批量公式二", "1"));
        ElnFormulaVersionEntity firstVersion = fixture.store.versions.get(
                first.getVersions().get(0).getId());
        firstVersion.setBizStatus("PUBLISHED");
        fixture.store.definitions.get(first.getId())
                .setDangqianGongshiBanbenId(firstVersion.getId());
        ElnFormulaVersionEntity secondVersion = fixture.store.versions.get(
                second.getVersions().get(0).getId());
        fixture.store.definitions.get(second.getId())
                .setDangqianGongshiBanbenId(secondVersion.getId());

        ElnFormulaDefEntity empty = new ElnFormulaDefEntity();
        empty.setId("formula-empty");
        empty.setFTenantId("tenant-1");
        empty.setGongshiBianma("formula_empty");
        empty.setGongshiMingcheng("无版本公式");
        empty.setBizEnabled("enabled");
        fixture.store.definitions.put(empty.getId(), empty);

        ElnFormulaVersionEntity foreign = new ElnFormulaVersionEntity();
        foreign.setId("foreign-version");
        foreign.setFTenantId("tenant-2");
        foreign.setGongshiDingyiId(first.getId());
        foreign.setBanbenHao(99);
        foreign.setBizStatus("PUBLISHED");
        fixture.store.versions.put(foreign.getId(), foreign);
        fixture.store.listVersionsCalls = 0;

        List<ElnFormulaVos.ListItem> records = fixture.service.page(query()).getRecords();
        Map<String, ElnFormulaVos.ListItem> byId = new LinkedHashMap<>();
        for (ElnFormulaVos.ListItem item : records) {
            byId.put(item.getId(), item);
        }

        assertEquals(0, fixture.store.listVersionsCalls);
        assertEquals(1, fixture.store.batchVersionCalls);
        assertEquals("tenant-1", fixture.store.batchVersionTenant);
        assertEquals(new LinkedHashSet<>(Arrays.asList(
                first.getId(), second.getId(), empty.getId())),
                fixture.store.batchVersionDefinitionIds);
        assertEquals(Integer.valueOf(1), byId.get(first.getId()).getDangqianBanbenHao());
        assertEquals(Integer.valueOf(1), byId.get(first.getId()).getZuixinFabuBanbenHao());
        assertEquals(Integer.valueOf(1), byId.get(second.getId()).getDangqianBanbenHao());
        assertNull(byId.get(second.getId()).getZuixinFabuBanbenHao());
        assertNull(byId.get(empty.getId()).getDangqianBanbenHao());
        assertNull(byId.get(empty.getId()).getZuixinFabuBanbenHao());
    }

    @Test
    public void detailReturnsStableTemplateReferenceSummariesWithMetadata() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail formula = fixture.service.create(formula("引用摘要", "1"));
        fixture.store.addTemplate(template("template-b", "tenant-1", "模板-B", "PUBLISHED"));
        fixture.store.addTemplate(template("template-a", "tenant-1", "模板-A", "DRAFT"));
        fixture.store.addFormulaBinding(binding("binding-b", "tenant-1", "template-b",
                formula.getId(), "version-2", "PENDING"));
        fixture.store.addFormulaBinding(binding("binding-a", "tenant-1", "template-a",
                formula.getId(), "version-1", "ACTIVE"));

        ElnFormulaVos.Detail detail = fixture.service.detail(formula.getId());
        List<?> references = (List<?>) property(detail, "templateReferences");

        assertEquals(2, references.size());
        assertEquals("binding-a", property(references.get(0), "bindingId"));
        assertEquals("template-a", property(references.get(0), "templateId"));
        assertEquals("模板-A", property(references.get(0), "templateName"));
        assertEquals("DRAFT", property(references.get(0), "templateStatus"));
        assertEquals("ACTIVE", property(references.get(0), "bindingStatus"));
        assertEquals("version-1", property(references.get(0), "formulaVersionId"));
        assertEquals("template-b", property(references.get(1), "templateId"));
    }

    @Test
    public void detailReturnsReferenceCountAndAtMostFivePreviews() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail formula = fixture.service.create(formula("大量引用", "1"));
        for (int index = 7; index >= 1; index--) {
            String templateId = "template-" + index;
            fixture.store.addTemplate(template(templateId, "tenant-1",
                    "模板-" + index, "PUBLISHED"));
            fixture.store.addFormulaBinding(binding("binding-" + index, "tenant-1",
                    templateId, formula.getId(), "version-" + index, "ACTIVE"));
        }

        ElnFormulaVos.Detail detail = fixture.service.detail(formula.getId());
        List<?> references = (List<?>) property(detail, "templateReferences");

        assertEquals(Integer.valueOf(7), property(detail, "mubanYinyongShu"));
        assertEquals(5, references.size());
        assertEquals("template-1", property(references.get(0), "templateId"));
        assertEquals("template-5", property(references.get(4), "templateId"));
    }

    @Test
    public void pagesLiveTemplateReferencesWithStableOrderAndTenantIsolation() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail formula = fixture.service.create(formula("分页引用", "1"));
        for (int index = 7; index >= 1; index--) {
            String templateId = "template-" + index;
            fixture.store.addTemplate(template(templateId, "tenant-1",
                    "模板-" + index, "PUBLISHED"));
            fixture.store.addFormulaBinding(binding("binding-" + index, "tenant-1",
                    templateId, formula.getId(), "version-" + index, "ACTIVE"));
        }
        fixture.store.addFormulaBinding(binding("binding-foreign", "tenant-2",
                "template-0", formula.getId(), "version-0", "ACTIVE"));
        fixture.store.addFormulaBinding(binding("binding-cancelled", "tenant-1",
                "template-8", formula.getId(), "version-8", "CANCELLED"));
        ElnFormulaForms.ReferenceQuery query = new ElnFormulaForms.ReferenceQuery();
        query.setCurrentPage(2);
        query.setPageSize(3);

        IPage<ElnFormulaVos.ReferenceSummary> page =
                fixture.service.pageTemplateReferences(formula.getId(), query);

        assertEquals(7, page.getTotal());
        assertEquals(3, page.getRecords().size());
        assertEquals("template-4", page.getRecords().get(0).getTemplateId());
        assertEquals("template-6", page.getRecords().get(2).getTemplateId());
    }

    @Test
    public void usesBindingIdAsTheFinalStableReferenceOrder() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail formula = fixture.service.create(formula("同键引用", "1"));
        fixture.store.addTemplate(template("template-1", "tenant-1",
                "模板-1", "PUBLISHED"));
        fixture.store.addFormulaBinding(binding("binding-z", "tenant-1",
                "template-1", formula.getId(), "version-1", "ACTIVE"));
        fixture.store.addFormulaBinding(binding("binding-a", "tenant-1",
                "template-1", formula.getId(), "version-1", "ACTIVE"));

        IPage<ElnFormulaVos.ReferenceSummary> page =
                fixture.service.pageTemplateReferences(
                        formula.getId(), new ElnFormulaForms.ReferenceQuery());

        assertEquals("binding-a", page.getRecords().get(0).getBindingId());
        assertEquals("binding-z", page.getRecords().get(1).getBindingId());
    }

    @Test
    public void filtersTemplateReferencesByTrimmedTemplateNameOrId() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail formula = fixture.service.create(formula("搜索引用", "1"));
        fixture.store.addTemplate(template("template-alpha", "tenant-1",
                "含量测定模板", "PUBLISHED"));
        fixture.store.addTemplate(template("template-beta", "tenant-1",
                "有关物质模板", "DRAFT"));
        fixture.store.addFormulaBinding(binding("binding-alpha", "tenant-1",
                "template-alpha", formula.getId(), "version-1", "ACTIVE"));
        fixture.store.addFormulaBinding(binding("binding-beta", "tenant-1",
                "template-beta", formula.getId(), "version-2", "PENDING"));
        ElnFormulaForms.ReferenceQuery byName = new ElnFormulaForms.ReferenceQuery();
        byName.setKeyword(" 含量测定 ");
        ElnFormulaForms.ReferenceQuery byId = new ElnFormulaForms.ReferenceQuery();
        byId.setKeyword(" beta ");

        IPage<ElnFormulaVos.ReferenceSummary> namePage =
                fixture.service.pageTemplateReferences(formula.getId(), byName);
        IPage<ElnFormulaVos.ReferenceSummary> idPage =
                fixture.service.pageTemplateReferences(formula.getId(), byId);

        assertEquals(1, namePage.getTotal());
        assertEquals("template-alpha", namePage.getRecords().get(0).getTemplateId());
        assertEquals(1, idPage.getTotal());
        assertEquals("template-beta", idPage.getRecords().get(0).getTemplateId());
    }

    @Test
    public void detailKeepsLiveReferenceWhenTemplateRecordIsMissingWithoutCrossTenantLeak() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail formula = fixture.service.create(formula("缺失模板", "1"));
        fixture.store.addFormulaBinding(binding("binding-missing", "tenant-1", "missing-template",
                formula.getId(), "version-1", "ACTIVE"));
        fixture.store.addFormulaBinding(binding("binding-foreign", "tenant-2", "foreign-template",
                formula.getId(), "version-2", "PENDING"));

        List<?> references = (List<?>) property(fixture.service.detail(formula.getId()),
                "templateReferences");

        assertEquals(1, references.size());
        assertEquals("missing-template", property(references.get(0), "templateId"));
        assertNull(property(references.get(0), "templateName"));
        assertNull(property(references.get(0), "templateStatus"));
    }

    @Test
    public void optimisticUpdateCountZeroFailsAndSuccessAdvancesEntityVersion() {
        expectDataException(() -> ElnFormulaCatalogServiceImpl.nextVersionAfterUpdate(
                0, 7, "版本冲突"));

        assertEquals(8, ElnFormulaCatalogServiceImpl.nextVersionAfterUpdate(
                1, 7, "版本冲突"));
    }

    @Test
    public void disableBlocksVersionAndPublishThenEnableRestoresLifecycle() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail created = fixture.service.create(formula("停用公式", "1"));
        String v1 = created.getVersions().get(0).getId();
        fixture.service.preRelease(v1);
        fixture.service.disable(created.getId(), "暂时停用");

        expectDataException(() -> fixture.service.publish(v1));
        expectDataException(() -> fixture.service.createVersion(created.getId(), copyOf(v1)));
        assertEquals("disabled", fixture.service.detail(created.getId()).getBizEnabled());

        fixture.service.enable(created.getId(), "恢复使用");
        fixture.service.publish(v1);
        assertEquals("enabled", fixture.service.detail(created.getId()).getBizEnabled());
    }

    @Test
    public void exposesTenantScopedAvailabilityForTemplateBindingGate() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail created = fixture.service.create(formula("引用门禁", "1"));

        assertTrue(fixture.service.isEnabled("tenant-1", created.getId()));
        assertFalse(fixture.service.isEnabled("other-tenant", created.getId()));
        fixture.service.disable(created.getId(), "停用");
        assertFalse(fixture.service.isEnabled("tenant-1", created.getId()));
    }

    @Test
    public void emitsEveryFixedLifecycleAuditAction() {
        Fixture fixture = new Fixture();
        ElnFormulaVos.Detail created = fixture.service.create(formula("审计公式", "1"));
        fixture.service.updateDefinition(created.getId(), definition("审计公式二"));
        String v1 = created.getVersions().get(0).getId();
        fixture.service.updateDraft(v1, version("2"));
        fixture.service.preRelease(v1);
        fixture.service.publish(v1);
        ElnFormulaVos.Version v2 = fixture.service.createVersion(created.getId(), copyOf(v1));
        fixture.service.cancel(v2.getId(), "废弃 V2");
        fixture.service.disable(created.getId(), "停用");
        fixture.service.enable(created.getId(), "启用");
        fixture.service.switchCurrent(created.getId(), v1, "切回 V1");

        assertEquals(Arrays.asList("ELN_FORMULA_CREATE", "ELN_FORMULA_VERSION_CREATE",
                        "ELN_FORMULA_UPDATE", "ELN_FORMULA_VERSION_UPDATE",
                        "ELN_FORMULA_VERSION_PRE_RELEASE", "ELN_FORMULA_VERSION_PUBLISH",
                        "ELN_FORMULA_VERSION_CREATE", "ELN_FORMULA_VERSION_CANCEL",
                        "ELN_FORMULA_DISABLE", "ELN_FORMULA_ENABLE",
                        "ELN_FORMULA_SWITCH_CURRENT"), fixture.auditActions());
        for (AuditEventDTO audit : fixture.audits) {
            assertTrue("eln_formula".equals(audit.getBizType())
                    || "eln_formula_version".equals(audit.getBizType()));
        }
    }

    private static ElnFormulaForms.Create formula(String name, String expression,
                                                   ElnFormulaForms.Parameter... parameters) {
        ElnFormulaForms.Create form = new ElnFormulaForms.Create();
        form.setGongshiMingcheng(name);
        form.setYewuYongtu("测试用途");
        form.setBiaodashi(expression);
        form.setJieguoLeixing("DECIMAL");
        form.setParameters(new ArrayList<>(Arrays.asList(parameters)));
        return form;
    }

    private static ElnFormulaForms.Parameter parameter(String name, String type) {
        ElnFormulaForms.Parameter form = new ElnFormulaForms.Parameter();
        form.setCanshuMingcheng(name);
        form.setShujuLeixing(type);
        form.setShifouBitian(1);
        return form;
    }

    private static ElnFormulaForms.Parameter parameterFrom(ElnFormulaVos.Parameter source) {
        ElnFormulaForms.Parameter form = parameter(source.getCanshuMingcheng(), source.getShujuLeixing());
        form.setId(source.getId());
        form.setDanwei(source.getDanwei());
        form.setPaixu(source.getPaixu());
        return form;
    }

    private static ElnFormulaForms.CreateVersion copyOf(String sourceVersionId) {
        ElnFormulaForms.CreateVersion form = new ElnFormulaForms.CreateVersion();
        form.setSourceVersionId(sourceVersionId);
        return form;
    }

    private static ElnFormulaForms.UpdateVersion version(String expression,
                                                          ElnFormulaForms.Parameter... parameters) {
        ElnFormulaForms.UpdateVersion form = new ElnFormulaForms.UpdateVersion();
        form.setBiaodashi(expression);
        form.setJieguoLeixing("DECIMAL");
        form.setParameters(new ArrayList<>(Arrays.asList(parameters)));
        return form;
    }

    private static ElnFormulaForms.UpdateDefinition definition(String name) {
        ElnFormulaForms.UpdateDefinition form = new ElnFormulaForms.UpdateDefinition();
        form.setGongshiMingcheng(name);
        form.setYewuYongtu("更新用途");
        return form;
    }

    private static String keptCode(ElnFormulaVos.Version version, int index) {
        return version.getParameters().get(index).getCanshuBianma();
    }

    private static void expectDataException(Runnable action) {
        try {
            action.run();
            fail("预期抛出 DataException");
        } catch (DataException expected) {
            assertFalse(expected.getMessage().trim().isEmpty());
        }
    }

    private static void expectDataException(String message, Runnable action) {
        try {
            action.run();
            fail("预期抛出 DataException");
        } catch (DataException expected) {
            assertTrue(expected.getMessage().contains(message));
        }
    }

    private static String repeat(String value, int count) {
        StringBuilder result = new StringBuilder();
        for (int i = 0; i < count; i++) {
            result.append(value);
        }
        return result.toString();
    }

    private static ElnFormulaForms.Query query() {
        ElnFormulaForms.Query query = new ElnFormulaForms.Query();
        query.setCurrentPage(1);
        query.setPageSize(20);
        return query;
    }

    private static ElnTemplateFormulaBindingEntity binding(String id, String tenantId,
                                                            String templateId, String formulaId,
                                                            String formulaVersionId, String status) {
        ElnTemplateFormulaBindingEntity result = new ElnTemplateFormulaBindingEntity();
        result.setId(id);
        result.setFTenantId(tenantId);
        result.setMubanId(templateId);
        result.setGongshiDingyiId(formulaId);
        result.setGongshiBanbenId(formulaVersionId);
        result.setBangdingZhuangtai(status);
        return result;
    }

    private static ElnTemplateVersionEntity template(String id, String tenantId,
                                                      String name, String status) {
        ElnTemplateVersionEntity result = new ElnTemplateVersionEntity();
        result.setId(id);
        result.setFTenantId(tenantId);
        result.setJianyanXiangmu(name);
        result.setBizStatus(status);
        return result;
    }

    private static Object property(Object source, String name) {
        try {
            Field field = source.getClass().getDeclaredField(name);
            field.setAccessible(true);
            return field.get(source);
        } catch (ReflectiveOperationException exception) {
            fail("缺少属性: " + name);
            return null;
        }
    }

    private static final class Fixture {
        private final MemoryStore store = new MemoryStore();
        private final List<AuditEventDTO> audits = new ArrayList<>();
        private final AtomicInteger ids = new AtomicInteger();
        private boolean hasDraftReference;
        private final ElnFormulaCatalogServiceImpl service;

        private Fixture(boolean checkerAvailable, String... suffixes) {
            Supplier<String> suffixSupplier = suffixSupplier(suffixes);
            service = new ElnFormulaCatalogServiceImpl(store,
                    new FormulaValidationServiceImpl(),
                    checkerAvailable ? (tenantId, versionId) -> hasDraftReference : null,
                    () -> new ElnFormulaCatalogServiceImpl.UserContext("tenant-1", "user-1"),
                    () -> "id-" + ids.incrementAndGet(),
                    new ElnFieldCodeGenerator(suffixSupplier), audits::add, () -> true);
        }

        private Fixture(String... suffixes) {
            this(true, suffixes);
        }

        private Fixture() {
            this(true, new String[0]);
        }

        private List<String> auditActions() {
            List<String> actions = new ArrayList<>();
            for (AuditEventDTO audit : audits) {
                actions.add(audit.getActionCode());
            }
            return actions;
        }

        private static Supplier<String> suffixSupplier(String[] configured) {
            AtomicInteger sequence = new AtomicInteger();
            return () -> {
                int index = sequence.getAndIncrement();
                return index < configured.length
                        ? configured[index] : String.format("s%07d", index + 1);
            };
        }
    }

    private static final class MemoryStore implements ElnFormulaCatalogServiceImpl.FormulaCatalogStore {
        private final Map<String, ElnFormulaDefEntity> definitions = new LinkedHashMap<>();
        private final Map<String, ElnFormulaVersionEntity> versions = new LinkedHashMap<>();
        private final Map<String, ElnFormulaParameterSlotEntity> slots = new LinkedHashMap<>();
        private final Map<String, ElnTemplateFormulaBindingEntity> formulaBindings = new LinkedHashMap<>();
        private final Map<String, ElnTemplateVersionEntity> templates = new LinkedHashMap<>();
        private int listVersionsCalls;
        private int batchVersionCalls;
        private String batchVersionTenant;
        private Set<String> batchVersionDefinitionIds = new LinkedHashSet<>();

        private void addFormulaBinding(ElnTemplateFormulaBindingEntity binding) {
            formulaBindings.put(binding.getId(), binding);
        }

        private void addTemplate(ElnTemplateVersionEntity template) {
            templates.put(template.getId(), template);
        }

        @Override
        public void insertDefinition(ElnFormulaDefEntity entity) {
            for (ElnFormulaDefEntity existing : definitions.values()) {
                if (existing.getFTenantId().equals(entity.getFTenantId())
                        && existing.getGongshiBianma().equals(entity.getGongshiBianma())) {
                    throw new DuplicateKeyException("duplicate formula code");
                }
            }
            definitions.put(entity.getId(), entity);
        }

        @Override
        public void insertVersion(ElnFormulaVersionEntity entity) {
            versions.put(entity.getId(), entity);
        }

        @Override
        public void insertSlot(ElnFormulaParameterSlotEntity entity) {
            for (ElnFormulaParameterSlotEntity existing : slots.values()) {
                if (existing.getFTenantId().equals(entity.getFTenantId())
                        && existing.getGongshiBanbenId().equals(entity.getGongshiBanbenId())
                        && existing.getCanshuBianma().equals(entity.getCanshuBianma())) {
                    throw new DuplicateKeyException("duplicate slot code");
                }
            }
            slots.put(entity.getId(), entity);
        }

        @Override
        public ElnFormulaDefEntity findDefinition(String tenantId, String id, boolean forUpdate) {
            ElnFormulaDefEntity value = definitions.get(id);
            return value != null && tenantId.equals(value.getFTenantId()) ? value : null;
        }

        @Override
        public ElnFormulaVersionEntity findVersion(String tenantId, String id, boolean forUpdate) {
            ElnFormulaVersionEntity value = versions.get(id);
            return value != null && tenantId.equals(value.getFTenantId()) ? value : null;
        }

        @Override
        public List<ElnFormulaVersionEntity> listVersions(String tenantId, String definitionId) {
            listVersionsCalls++;
            List<ElnFormulaVersionEntity> result = new ArrayList<>();
            for (ElnFormulaVersionEntity value : versions.values()) {
                if (tenantId.equals(value.getFTenantId())
                        && definitionId.equals(value.getGongshiDingyiId())) {
                    result.add(value);
                }
            }
            return result;
        }

        @Override
        public List<ElnFormulaVersionEntity> listVersionsByDefinitionIds(
                String tenantId, Collection<String> definitionIds) {
            batchVersionCalls++;
            batchVersionTenant = tenantId;
            batchVersionDefinitionIds = new LinkedHashSet<>(definitionIds);
            List<ElnFormulaVersionEntity> result = new ArrayList<>();
            for (ElnFormulaVersionEntity value : versions.values()) {
                if (tenantId.equals(value.getFTenantId())
                        && definitionIds.contains(value.getGongshiDingyiId())) {
                    result.add(value);
                }
            }
            return result;
        }

        @Override
        public List<ElnFormulaParameterSlotEntity> listSlots(String tenantId, String versionId) {
            List<ElnFormulaParameterSlotEntity> result = new ArrayList<>();
            for (ElnFormulaParameterSlotEntity value : slots.values()) {
                if (tenantId.equals(value.getFTenantId())
                        && versionId.equals(value.getGongshiBanbenId())) {
                    result.add(value);
                }
            }
            return result;
        }

        @Override
        public List<ElnTemplateFormulaBindingEntity> listLiveTemplateFormulaBindings(
                String tenantId, java.util.Collection<String> definitionIds) {
            List<ElnTemplateFormulaBindingEntity> result = new ArrayList<>();
            for (ElnTemplateFormulaBindingEntity binding : formulaBindings.values()) {
                if (tenantId.equals(binding.getFTenantId())
                        && definitionIds.contains(binding.getGongshiDingyiId())
                        && ("ACTIVE".equals(binding.getBangdingZhuangtai())
                        || "PENDING".equals(binding.getBangdingZhuangtai()))) {
                    result.add(binding);
                }
            }
            return result;
        }

        @Override
        public IPage<ElnTemplateFormulaBindingEntity> pageLiveTemplateFormulaBindings(
                String tenantId, String definitionId, ElnFormulaForms.ReferenceQuery query) {
            List<ElnTemplateFormulaBindingEntity> result = new ArrayList<>();
            String keyword = query.getKeyword() == null ? null : query.getKeyword().trim();
            for (ElnTemplateFormulaBindingEntity binding : formulaBindings.values()) {
                ElnTemplateVersionEntity template = templates.get(binding.getMubanId());
                boolean matchesKeyword = keyword == null || keyword.isEmpty()
                        || binding.getMubanId().contains(keyword)
                        || template != null && template.getJianyanXiangmu().contains(keyword);
                if (tenantId.equals(binding.getFTenantId())
                        && definitionId.equals(binding.getGongshiDingyiId())
                        && ("ACTIVE".equals(binding.getBangdingZhuangtai())
                        || "PENDING".equals(binding.getBangdingZhuangtai()))
                        && matchesKeyword) {
                    result.add(binding);
                }
            }
            result.sort(Comparator.comparing(ElnTemplateFormulaBindingEntity::getMubanId)
                    .thenComparing(ElnTemplateFormulaBindingEntity::getGongshiBanbenId)
                    .thenComparing(ElnTemplateFormulaBindingEntity::getBangdingZhuangtai)
                    .thenComparing(ElnTemplateFormulaBindingEntity::getId));
            int from = Math.min((query.getCurrentPage() - 1) * query.getPageSize(), result.size());
            int to = Math.min(from + query.getPageSize(), result.size());
            return new Page<ElnTemplateFormulaBindingEntity>(
                    query.getCurrentPage(), query.getPageSize(), result.size())
                    .setRecords(new ArrayList<>(result.subList(from, to)));
        }

        @Override
        public List<ElnTemplateVersionEntity> listTemplates(
                String tenantId, java.util.Collection<String> templateIds) {
            List<ElnTemplateVersionEntity> result = new ArrayList<>();
            for (ElnTemplateVersionEntity template : templates.values()) {
                if (tenantId.equals(template.getFTenantId()) && templateIds.contains(template.getId())) {
                    result.add(template);
                }
            }
            return result;
        }

        @Override
        public IPage<ElnFormulaDefEntity> page(String tenantId, ElnFormulaForms.Query query) {
            List<ElnFormulaDefEntity> result = new ArrayList<>();
            for (ElnFormulaDefEntity value : definitions.values()) {
                if (tenantId.equals(value.getFTenantId())) {
                    result.add(value);
                }
            }
            return new Page<ElnFormulaDefEntity>(query.getCurrentPage(), query.getPageSize())
                    .setRecords(result).setTotal(result.size());
        }

        @Override
        public void updateDefinition(ElnFormulaDefEntity entity) {
            definitions.put(entity.getId(), entity);
        }

        @Override
        public void updateVersion(ElnFormulaVersionEntity entity) {
            versions.put(entity.getId(), entity);
        }

        @Override
        public void updateSlot(ElnFormulaParameterSlotEntity entity) {
            slots.put(entity.getId(), entity);
        }

        @Override
        public void deleteSlot(ElnFormulaParameterSlotEntity entity) {
            slots.remove(entity.getId());
        }
    }
}