package jnpf.elnService.impl;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import jnpf.audit.model.AuditEventDTO;
import jnpf.elnEntity.field.ElnFieldDefEntity;
import jnpf.elnEntity.field.ElnFieldForms;
import jnpf.elnEntity.field.ElnFieldVersionEntity;
import jnpf.elnEntity.field.ElnFieldVos;
import jnpf.elnService.ElnFieldProviderCatalog;
import jnpf.exception.DataException;
import org.junit.Test;
import org.springframework.dao.DuplicateKeyException;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
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 ElnFieldCatalogServiceImplTest {

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

        ElnFieldVos.Detail detail = fixture.service.create(textField("检验依据"));

        assertEquals("GLOBAL", detail.getZuoyongFanwei());
        assertEquals("enabled", detail.getBizEnabled());
        assertTrue(detail.getZiduanBianma().matches("jianyan_yiju_[a-z0-9]{8}"));
        assertEquals(1, detail.getVersions().size());
        assertEquals(Integer.valueOf(1), detail.getVersions().get(0).getBanbenHao());
        assertEquals("DRAFT", detail.getVersions().get(0).getBizStatus());
        assertNull(detail.getDangqianZiduanBanbenId());
        assertEquals(Arrays.asList("ELN_FIELD_CREATE", "ELN_FIELD_VERSION_CREATE"),
                fixture.auditActions());
    }

    @Test
    public void createsGlobalCheckboxWithDefaultSelectionGroupRecommendation() {
        Fixture fixture = new Fixture();
        ElnFieldForms.Create form = checkboxField("复核结论");
        form.setRecommendedCheckboxGroupCode("review_result");

        ElnFieldVos.Version version = fixture.service.create(form).getVersions().get(0);

        assertEquals("review_result", version.getRecommendedCheckboxGroupCode());
        assertEquals(Integer.valueOf(0), version.getRecommendedCheckboxMinSelected());
        assertEquals(Integer.valueOf(1), version.getRecommendedCheckboxMaxSelected());
    }

    @Test
    public void supportsArbitraryAndUnlimitedSelectionRecommendations() {
        Fixture fixture = new Fixture();
        ElnFieldForms.Create bounded = checkboxField("多项结论");
        bounded.setRecommendedCheckboxGroupCode("multi_result");
        bounded.setRecommendedCheckboxMinSelected(4);
        bounded.setRecommendedCheckboxMaxSelected(7);
        ElnFieldForms.Create unlimited = checkboxField("补充结论");
        unlimited.setRecommendedCheckboxGroupCode("extra_result");
        unlimited.setRecommendedCheckboxMinSelected(2);
        unlimited.setRecommendedCheckboxMaxSelected(null);

        ElnFieldVos.Version boundedVersion = fixture.service.create(bounded).getVersions().get(0);
        ElnFieldVos.Version unlimitedVersion = fixture.service.create(unlimited).getVersions().get(0);

        assertEquals(Integer.valueOf(4), boundedVersion.getRecommendedCheckboxMinSelected());
        assertEquals(Integer.valueOf(7), boundedVersion.getRecommendedCheckboxMaxSelected());
        assertEquals(Integer.valueOf(2), unlimitedVersion.getRecommendedCheckboxMinSelected());
        assertNull(unlimitedVersion.getRecommendedCheckboxMaxSelected());
    }

    @Test
    public void rejectsInvalidOrIneligibleSelectionRecommendations() {
        Fixture fixture = new Fixture();
        ElnFieldForms.Create text = textField("文本");
        text.setRecommendedCheckboxGroupCode("text_group");
        expectDataException(() -> fixture.service.create(text));

        ElnFieldForms.Create invalidCode = checkboxField("非法编码");
        invalidCode.setRecommendedCheckboxGroupCode("中文组");
        expectDataException(() -> fixture.service.create(invalidCode));

        ElnFieldForms.Create negativeMin = checkboxField("非法最少数");
        negativeMin.setRecommendedCheckboxGroupCode("negative_min");
        negativeMin.setRecommendedCheckboxMinSelected(-1);
        expectDataException(() -> fixture.service.create(negativeMin));

        ElnFieldForms.Create zeroMax = checkboxField("非法最多数");
        zeroMax.setRecommendedCheckboxGroupCode("zero_max");
        zeroMax.setRecommendedCheckboxMaxSelected(0);
        expectDataException(() -> fixture.service.create(zeroMax));

        ElnFieldForms.Create inverted = checkboxField("倒置范围");
        inverted.setRecommendedCheckboxGroupCode("inverted");
        inverted.setRecommendedCheckboxMinSelected(3);
        inverted.setRecommendedCheckboxMaxSelected(2);
        expectDataException(() -> fixture.service.create(inverted));

        ElnFieldForms.Create external = externalField("test.basis", "RECORD_PRIVATE");
        external.setShujuLeixing("CHECKBOX");
        external.setRecommendedCheckboxGroupCode("external_group");
        expectDataException(() -> fixture.service.create(external));
    }

    @Test
    public void copiesSelectionRecommendationIntoNewDraftVersion() {
        Fixture fixture = new Fixture();
        ElnFieldForms.Create form = checkboxField("复核意见");
        form.setRecommendedCheckboxGroupCode("review_options");
        form.setRecommendedCheckboxMinSelected(1);
        form.setRecommendedCheckboxMaxSelected(4);
        ElnFieldVos.Detail created = fixture.service.create(form);
        String sourceId = created.getVersions().get(0).getId();
        fixture.service.preRelease(sourceId);

        ElnFieldVos.Version copied = fixture.service.createVersion(created.getId(), copyOf(sourceId));

        assertEquals("review_options", copied.getRecommendedCheckboxGroupCode());
        assertEquals(Integer.valueOf(1), copied.getRecommendedCheckboxMinSelected());
        assertEquals(Integer.valueOf(4), copied.getRecommendedCheckboxMaxSelected());
    }

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

        String first = fixture.service.create(textField("同名字段")).getZiduanBianma();
        String second = fixture.service.create(textField("同名字段")).getZiduanBianma();
        String longCode = fixture.service.create(textField(repeat("超长字段", 30))).getZiduanBianma();
        String numericCode = fixture.service.create(textField("123温度")).getZiduanBianma();
        String fallbackCode = fixture.service.create(textField("***")).getZiduanBianma();

        assertNotEquals(first, second);
        assertTrue(longCode.length() <= 80);
        assertTrue(numericCode.startsWith("f_123_wendu_"));
        assertTrue(fallbackCode.startsWith("field_"));
        assertTrue(longCode.matches("[a-z][a-z0-9_]*"));
    }

    @Test
    public void retriesCodeCollisionAtMostThreeTimes() {
        Fixture fixture = new Fixture("same0001", "same0001", "next0002");
        fixture.service.create(textField("字段"));

        ElnFieldVos.Detail second = fixture.service.create(textField("字段"));

        assertTrue(second.getZiduanBianma().endsWith("next0002"));
    }

    @Test
    public void publishesImmutableVersionAndSwitchesOnlyWithinIdentity() {
        Fixture fixture = new Fixture();
        ElnFieldVos.Detail first = fixture.service.create(textField("观察结果"));
        String firstVersionId = first.getVersions().get(0).getId();
        ElnFieldVos.Detail other = fixture.service.create(textField("结论"));

        fixture.service.preRelease(firstVersionId);
        fixture.service.publish(firstVersionId);
        fixture.service.switchCurrent(first.getId(), firstVersionId, "首次启用");

        assertEquals(firstVersionId, fixture.service.detail(first.getId()).getDangqianZiduanBanbenId());
        expectDataException(() -> fixture.service.updateDraft(firstVersionId, versionUpdate("修改")));
        expectDataException(() -> fixture.service.switchCurrent(
                first.getId(), other.getVersions().get(0).getId(), "错误切换"));
    }

    @Test
    public void refusesAnUnpublishedPinnedRevisionEvenWhenThePropertyCodeExists() {
        Fixture fixture = new Fixture();
        ElnFieldForms.Create form = externalField("test.basis", "RECORD_PRIVATE");
        form.getBinding().getRead().setPropertyRevision(99);
        ElnFieldVos.Detail created = fixture.service.create(form);
        String versionId = created.getVersions().get(0).getId();

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

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

    @Test
    public void rechecksPinnedSourceWhenPublishingAPreReleasedField() {
        Fixture fixture = new Fixture();
        fixture.providerCatalog.properties.set(0, new ElnFieldProviderCatalog.Property(
                "LIMS_TASK", "test.basis", "Basis V1", "TEXT", true, 1, true));
        ElnFieldForms.Create form = externalField("test.basis", "RECORD_PRIVATE");
        form.getBinding().getRead().setPropertyRevision(1);
        ElnFieldVos.Detail created = fixture.service.create(form);
        String versionId = created.getVersions().get(0).getId();
        fixture.service.preRelease(versionId);
        fixture.providerCatalog.properties.set(0, new ElnFieldProviderCatalog.Property(
                "LIMS_TASK", "test.basis", "Basis V1", "TEXT", true, 1, false));

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

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

    @Test
    public void publishesABooleanCheckboxWithItsPinnedSourceRevision() {
        Fixture fixture = new Fixture();
        fixture.providerCatalog.properties.set(0, new ElnFieldProviderCatalog.Property(
                "LIMS_TASK", "task.external", "External test", "BOOLEAN", true, 1, true));
        ElnFieldForms.Create form = externalField("task.external", "RECORD_PRIVATE");
        form.setShujuLeixing("CHECKBOX");
        form.getBinding().getRead().setPropertyRevision(1);
        ElnFieldVos.Detail created = fixture.service.create(form);
        String versionId = created.getVersions().get(0).getId();

        fixture.service.preRelease(versionId);
        fixture.service.publish(versionId);

        ElnFieldVos.Version published = fixture.service.detail(created.getId()).getVersions().get(0);
        assertEquals("PUBLISHED", published.getBizStatus());
        assertEquals(Integer.valueOf(1), published.getBinding().getRead().getPropertyRevision());
    }

    @Test
    public void revalidatesPublishedVersionBeforeSwitchingCurrent() {
        Fixture fixture = new Fixture();
        ElnFieldVos.Detail created = fixture.service.create(
                externalField("test.basis", "RECORD_PRIVATE"));
        String versionId = created.getVersions().get(0).getId();
        fixture.service.preRelease(versionId);
        fixture.service.publish(versionId);
        fixture.providerCatalog.available = false;

        expectDataException(() -> fixture.service.switchCurrent(
                created.getId(), versionId, "切换前重新校验"));

        assertNull(fixture.service.detail(created.getId()).getDangqianZiduanBanbenId());
    }

    @Test
    public void copiesPublishedRulesWithoutMovingPointerAndNeverReusesVersionNumber() {
        Fixture fixture = new Fixture();
        ElnFieldVos.Detail created = fixture.service.create(textField("温度"));
        String v1 = created.getVersions().get(0).getId();
        fixture.service.preRelease(v1);
        fixture.service.publish(v1);
        fixture.service.switchCurrent(created.getId(), v1, "启用 V1");

        ElnFieldVos.Version v2 = fixture.service.createVersion(created.getId(), copyOf(v1));
        fixture.service.cancel(v2.getId(), "不再使用");
        ElnFieldVos.Version v3 = fixture.service.createVersion(created.getId(), copyOf(v1));

        assertEquals(Integer.valueOf(2), v2.getBanbenHao());
        assertEquals(Integer.valueOf(3), v3.getBanbenHao());
        assertEquals("温度", v3.getZiduanMingcheng());
        assertEquals(v1, fixture.service.detail(created.getId()).getDangqianZiduanBanbenId());
    }

    @Test
    public void disablesNewVersionsAndSwitchesButCanEnableAgain() {
        Fixture fixture = new Fixture();
        ElnFieldVos.Detail created = fixture.service.create(textField("批号"));
        String versionId = created.getVersions().get(0).getId();
        fixture.service.preRelease(versionId);
        fixture.service.publish(versionId);

        fixture.service.disable(created.getId(), "字段退役");
        expectDataException(() -> fixture.service.createVersion(created.getId(), copyOf(versionId)));
        expectDataException(() -> fixture.service.switchCurrent(created.getId(), versionId, "停用后切换"));

        fixture.service.enable(created.getId(), "恢复使用");
        fixture.service.switchCurrent(created.getId(), versionId, "恢复后启用");
        assertEquals("enabled", fixture.service.detail(created.getId()).getBizEnabled());
    }

    @Test
    public void createsTemplateFieldOnlyThroughTenantBoundInternalCommand() {
        Fixture fixture = new Fixture();
        ElnFieldForms.TemplateFieldCreate command = new ElnFieldForms.TemplateFieldCreate();
        command.setTenantId("tenant-1");
        command.setTemplateCode("TPL-001");
        command.setOperatorId("user-1");
        command.setZiduanMingcheng("检验观察项");
        command.setShujuLeixing("TEXTAREA");

        ElnFieldVos.Detail detail = fixture.service.createTemplateFieldAndPreRelease(command);

        assertEquals("TEMPLATE", detail.getZuoyongFanwei());
        assertEquals("TPL-001", detail.getMubanBianhao());
        assertTrue(detail.getZiduanBianma(), detail.getZiduanBianma().matches(
                "p_jianyan_guancha_xiang_[a-z0-9]{8}"));
        assertEquals("PRE_RELEASE", detail.getVersions().get(0).getBizStatus());
        assertEquals("NONE", detail.getVersions().get(0).getBinding().getRead().getSource());

        command.setTenantId("tenant-2");
        expectDataException(() -> fixture.service.createTemplateFieldAndPreRelease(command));
    }

    @Test
    public void rejectsDuplicateEnabledTemplateFieldNameWithinTheSameTemplate() {
        Fixture fixture = new Fixture("first01", "second02");
        ElnFieldForms.TemplateFieldCreate first = templateCommand();
        ElnFieldForms.TemplateFieldCreate duplicate = templateCommand();

        fixture.service.createTemplateFieldAndPreRelease(first);

        expectDataException(() -> fixture.service.createTemplateFieldAndPreRelease(duplicate));
    }

    @Test
    public void allowsReusingTheNameOfADisabledTemplateField() {
        Fixture fixture = new Fixture("first01", "second02");
        ElnFieldForms.TemplateFieldCreate first = templateCommand();
        ElnFieldVos.Detail disabled = fixture.service.createTemplateFieldAndPreRelease(first);
        fixture.service.disable(disabled.getId(), "停用旧模板字段");

        ElnFieldVos.Detail replacement = fixture.service.createTemplateFieldAndPreRelease(
                templateCommand());

        assertNotEquals(disabled.getId(), replacement.getId());
    }

    @Test
    public void rejectsFieldLevelSelectionRecommendationForTemplatePrivateField() {
        Fixture fixture = new Fixture();
        ElnFieldForms.TemplateFieldCreate command = templateCommand();
        command.setShujuLeixing("CHECKBOX");
        command.setRecommendedCheckboxGroupCode("private_result");

        expectDataException(() -> fixture.service.createTemplateFieldAndPreRelease(command));
    }

    @Test
    public void promotesTemplateIdentityWithoutChangingCodeVersionsOrPointer() {
        Fixture fixture = new Fixture();
        ElnFieldForms.TemplateFieldCreate command = templateCommand();
        ElnFieldVos.Detail created = fixture.service.createTemplateFieldAndPreRelease(command);
        String code = created.getZiduanBianma();
        String versionId = created.getVersions().get(0).getId();
        fixture.service.publish(versionId);
        fixture.service.switchCurrent(created.getId(), versionId, "启用私有字段");

        fixture.service.promoteToGlobal(created.getId(), "升级为公共字段");

        ElnFieldVos.Detail promoted = fixture.service.detail(created.getId());
        assertEquals("GLOBAL", promoted.getZuoyongFanwei());
        assertNull(promoted.getMubanBianhao());
        assertEquals(code, promoted.getZiduanBianma());
        assertEquals(versionId, promoted.getDangqianZiduanBanbenId());
        assertEquals(1, promoted.getVersions().size());

        expectDataException(() -> fixture.service.promoteToGlobal(created.getId(), "重复升格"));
    }

    @Test
    public void rejectsPromotionWithoutPermissionAndPublicTemplateCreation() {
        Fixture fixture = new Fixture();
        ElnFieldForms.Create publicForm = textField("非法私有字段");
        publicForm.setZuoyongFanwei("TEMPLATE");
        expectDataException(() -> fixture.service.create(publicForm));

        ElnFieldVos.Detail template = fixture.service.createTemplateFieldAndPreRelease(templateCommand());
        fixture.promoteAllowed = false;
        expectDataException(() -> fixture.service.promoteToGlobal(template.getId(), "无权限"));
    }

    @Test
    public void rejectsCatalogMaintenanceAndPrivateFieldReadsWithoutPermission() {
        Fixture fixture = new Fixture();
        ElnFieldVos.Detail template = fixture.service.createTemplateFieldAndPreRelease(
                templateCommand());
        fixture.maintainAllowed = false;

        expectDataException(() -> fixture.service.create(textField("无权限创建")));
        expectDataException(() -> fixture.service.page(new ElnFieldForms.Query()));
        expectDataException(() -> fixture.service.detail(template.getId()));
        expectDataException(() -> fixture.service.publish(
                template.getVersions().get(0).getId()));
    }

    @Test
    public void validatesProviderPropertyScopeAndBatchModeBeforePreRelease() {
        Fixture fixture = new Fixture();
        ElnFieldForms.Create invalidProperty = externalField("test.unknown", "RECORD_PRIVATE");
        ElnFieldVos.Detail first = fixture.service.create(invalidProperty);
        expectDataException(() -> fixture.service.preRelease(first.getVersions().get(0).getId()));

        ElnFieldForms.Create invalidBatch = externalField("test.basis", "BATCH_SHARED");
        ElnFieldVos.Detail second = fixture.service.create(invalidBatch);
        expectDataException(() -> fixture.service.preRelease(second.getVersions().get(0).getId()));

        ElnFieldForms.Create valid = externalField("test.basis", "RECORD_PRIVATE");
        ElnFieldVos.Detail third = fixture.service.create(valid);
        fixture.service.preRelease(third.getVersions().get(0).getId());
        assertEquals("PRE_RELEASE", fixture.service.detail(third.getId()).getVersions().get(0).getBizStatus());
    }

    @Test
    public void validatesProviderTypeAndControlConfigBeforePreRelease() {
        Fixture fixture = new Fixture();
        ElnFieldForms.Create invalidType = externalField(
                "test.basis", "RECORD_PRIVATE");
        invalidType.setShujuLeixing("CHECKBOX");
        ElnFieldVos.Detail first = fixture.service.create(invalidType);
        expectDataException(() -> fixture.service.preRelease(
                first.getVersions().get(0).getId()));

        ElnFieldVos.Detail second = fixture.service.create(textField("控件配置"));
        ElnFieldVersionEntity stored = fixture.store.findVersion(
                "tenant-1", second.getVersions().get(0).getId());
        stored.setKongjianPeizhi("[]");
        expectDataException(() -> fixture.service.preRelease(stored.getId()));
    }

    private static ElnFieldForms.Create textField(String name) {
        ElnFieldForms.Create form = new ElnFieldForms.Create();
        form.setZiduanMingcheng(name);
        form.setShujuLeixing("TEXT");
        form.setShifouBitian(0);
        form.setPiciMoshi("RECORD_PRIVATE");
        form.setBinding(binding("NONE", null));
        return form;
    }

    private static ElnFieldForms.Create checkboxField(String name) {
        ElnFieldForms.Create form = textField(name);
        form.setShujuLeixing("CHECKBOX");
        return form;
    }

    private static ElnFieldForms.Create externalField(String property, String batchMode) {
        ElnFieldForms.Create form = textField("检验依据");
        form.setPiciMoshi(batchMode);
        form.setBinding(binding("LIMS_TASK", property));
        return form;
    }

    private static ElnFieldForms.Binding binding(String source, String property) {
        ElnFieldForms.Read read = new ElnFieldForms.Read();
        read.setSource(source);
        read.setProperty(property);
        ElnFieldForms.Write write = new ElnFieldForms.Write();
        write.setTarget("ELN_RECORD");
        ElnFieldForms.Binding binding = new ElnFieldForms.Binding();
        binding.setRead(read);
        binding.setWrite(write);
        return binding;
    }

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

    private static ElnFieldForms.VersionUpdate versionUpdate(String name) {
        ElnFieldForms.VersionUpdate form = new ElnFieldForms.VersionUpdate();
        form.setZiduanMingcheng(name);
        form.setShujuLeixing("TEXT");
        form.setShifouBitian(0);
        form.setPiciMoshi("RECORD_PRIVATE");
        form.setBinding(binding("NONE", null));
        return form;
    }

    private static ElnFieldForms.TemplateFieldCreate templateCommand() {
        ElnFieldForms.TemplateFieldCreate command = new ElnFieldForms.TemplateFieldCreate();
        command.setTenantId("tenant-1");
        command.setTemplateCode("TPL-001");
        command.setOperatorId("user-1");
        command.setZiduanMingcheng("模板字段");
        command.setShujuLeixing("TEXT");
        return command;
    }

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

    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 final class Fixture {
        private final MemoryStore store = new MemoryStore();
        private final List<AuditEventDTO> audits = new ArrayList<>();
        private final AtomicInteger ids = new AtomicInteger();
        private final TestProviderCatalog providerCatalog = new TestProviderCatalog();
        private boolean maintainAllowed = true;
        private boolean promoteAllowed = true;
        private final ElnFieldCatalogServiceImpl service;

        private Fixture(String... suffixes) {
            Supplier<String> suffixSupplier = suffixSupplier(suffixes);
            service = new ElnFieldCatalogServiceImpl(
                    store,
                    providerCatalog,
                    () -> new ElnFieldCatalogServiceImpl.UserContext("tenant-1", "user-1"),
                    () -> "id-" + ids.incrementAndGet(),
                    new ElnFieldCodeGenerator(suffixSupplier),
                    audits::add,
                    () -> maintainAllowed,
                    () -> promoteAllowed);
        }

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

        private List<String> auditActions() {
            List<String> actions = new ArrayList<>();
            for (AuditEventDTO event : audits) {
                actions.add(event.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 TestProviderCatalog implements ElnFieldProviderCatalog {
        private boolean available = true;
        private final List<Property> properties = Arrays.asList(
                new Property("LIMS_TASK", "test.basis", "检验依据", "TEXT", true),
                new Property("SYSTEM", "current_user.id", "当前用户", "TEXT", true));

        @Override
        public List<Property> list(String source) {
            List<Property> result = new ArrayList<>();
            if (!available) {
                return result;
            }
            for (Property property : properties) {
                if (property.getSource().equals(source)) {
                    result.add(property);
                }
            }
            return result;
        }

        @Override
        public boolean contains(String source, String property) {
            if (!available) {
                return false;
            }
            for (Property item : properties) {
                if (item.getSource().equals(source) && item.getProperty().equals(property)) {
                    return true;
                }
            }
            return false;
        }
    }

    private static final class MemoryStore implements ElnFieldCatalogServiceImpl.FieldCatalogStore {
        private final Map<String, ElnFieldDefEntity> definitions = new LinkedHashMap<>();
        private final Map<String, ElnFieldVersionEntity> versions = new LinkedHashMap<>();

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

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

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

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

        @Override
        public List<ElnFieldVersionEntity> listVersions(String tenantId, String definitionId) {
            List<ElnFieldVersionEntity> result = new ArrayList<>();
            for (ElnFieldVersionEntity version : versions.values()) {
                if (tenantId.equals(version.getFTenantId())
                        && definitionId.equals(version.getZiduanDingyiId())) {
                    result.add(version);
                }
            }
            return result;
        }

        @Override
        public boolean hasEnabledTemplateFieldName(String tenantId, String templateCode,
                                                   String fieldName) {
            for (ElnFieldDefEntity definition : definitions.values()) {
                if (!tenantId.equals(definition.getFTenantId())
                        || !"TEMPLATE".equals(definition.getZuoyongFanwei())
                        || !templateCode.equals(definition.getMubanBianhao())
                        || !"enabled".equals(definition.getBizEnabled())) {
                    continue;
                }
                for (ElnFieldVersionEntity version : versions.values()) {
                    if (tenantId.equals(version.getFTenantId())
                            && definition.getId().equals(version.getZiduanDingyiId())
                            && fieldName.equals(version.getZiduanMingcheng())) {
                        return true;
                    }
                }
            }
            return false;
        }

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

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

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