findByEventTimeBetweenOrderByEventTimeDesc(OffsetDateTime from, OffsetDateTime to);
+}
diff --git a/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/config/JpaAuditingConfig.java b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/config/JpaAuditingConfig.java
new file mode 100644
index 0000000..34e9e3b
--- /dev/null
+++ b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/config/JpaAuditingConfig.java
@@ -0,0 +1,32 @@
+package cloud.nstart.terravault.ordinis.domain.config;
+
+import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.domain.AuditorAware;
+import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+
+import javax.sql.DataSource;
+import java.util.Optional;
+
+/**
+ * Включает {@code @CreatedBy}/{@code @LastModifiedBy}. Domain не знает откуда
+ * приходит user identity — модули выше (app, rest-api) подключают свой
+ * {@link AuditorAware} (JWT subject из @nstart/auth). Default тут возвращает
+ * {@code "system"} для batch/internal операций.
+ *
+ * {@link ConditionalOnBean} на {@link DataSource} — без БД (dev smoke
+ * profile) auditing не активируется, JPA metamodel не строится.
+ */
+@Configuration
+@ConditionalOnBean(DataSource.class)
+@EnableJpaAuditing(auditorAwareRef = "auditorAware")
+public class JpaAuditingConfig {
+
+ @Bean
+ @ConditionalOnMissingBean(AuditorAware.class)
+ public AuditorAware auditorAware() {
+ return () -> Optional.of("system");
+ }
+}
diff --git a/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/definition/DictionaryDefinition.java b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/definition/DictionaryDefinition.java
new file mode 100644
index 0000000..39c7bf2
--- /dev/null
+++ b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/definition/DictionaryDefinition.java
@@ -0,0 +1,122 @@
+package cloud.nstart.terravault.ordinis.domain.definition;
+
+import cloud.nstart.terravault.ordinis.domain.DataScope;
+import com.fasterxml.jackson.databind.JsonNode;
+import io.hypersistence.utils.hibernate.type.array.StringArrayType;
+import io.hypersistence.utils.hibernate.type.json.JsonType;
+import jakarta.persistence.Column;
+import jakarta.persistence.EnumType;
+import jakarta.persistence.Enumerated;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import jakarta.persistence.Version;
+import org.hibernate.annotations.Type;
+import org.springframework.data.annotation.CreatedBy;
+import org.springframework.data.annotation.CreatedDate;
+import org.springframework.data.annotation.LastModifiedBy;
+import org.springframework.data.annotation.LastModifiedDate;
+import org.springframework.data.jpa.domain.support.AuditingEntityListener;
+
+import jakarta.persistence.EntityListeners;
+
+import java.time.OffsetDateTime;
+import java.util.UUID;
+
+/**
+ * Каталоговый entity справочника: имя, JSON Schema, scope, поддерживаемые локали.
+ * Read-mostly — обновления редкие (admin operation). Не Audited через Envers
+ * (история через audit_log + outbox).
+ */
+@Entity
+@Table(name = "dictionary_definitions")
+@EntityListeners(AuditingEntityListener.class)
+public class DictionaryDefinition {
+
+ @Id
+ @Column(name = "id", nullable = false, updatable = false)
+ private UUID id;
+
+ @Column(name = "name", nullable = false, unique = true, length = 128)
+ private String name;
+
+ @Column(name = "display_name", length = 256)
+ private String displayName;
+
+ @Column(name = "description", columnDefinition = "TEXT")
+ private String description;
+
+ @Enumerated(EnumType.STRING)
+ @Column(name = "scope", nullable = false, length = 32)
+ private DataScope scope;
+
+ @Type(JsonType.class)
+ @Column(name = "schema_json", nullable = false, columnDefinition = "jsonb")
+ private JsonNode schemaJson;
+
+ @Column(name = "schema_version", nullable = false, length = 32)
+ private String schemaVersion = "1.0.0";
+
+ @Column(name = "bundle", nullable = false, length = 64)
+ private String bundle = "cuod";
+
+ @Type(StringArrayType.class)
+ @Column(name = "supported_locales", nullable = false, columnDefinition = "text[]")
+ private String[] supportedLocales = {"ru-RU"};
+
+ @Column(name = "default_locale", nullable = false, length = 10)
+ private String defaultLocale = "ru-RU";
+
+ @CreatedDate
+ @Column(name = "created_at", nullable = false, updatable = false)
+ private OffsetDateTime createdAt;
+
+ @LastModifiedDate
+ @Column(name = "updated_at", nullable = false)
+ private OffsetDateTime updatedAt;
+
+ @CreatedBy
+ @Column(name = "created_by", length = 128, updatable = false)
+ private String createdBy;
+
+ @LastModifiedBy
+ @Column(name = "updated_by", length = 128)
+ private String updatedBy;
+
+ @Version
+ @Column(name = "version")
+ private Long version;
+
+ protected DictionaryDefinition() {}
+
+ public DictionaryDefinition(UUID id, String name, DataScope scope, JsonNode schemaJson) {
+ this.id = id;
+ this.name = name;
+ this.scope = scope;
+ this.schemaJson = schemaJson;
+ }
+
+ public UUID getId() { return id; }
+ public String getName() { return name; }
+ public String getDisplayName() { return displayName; }
+ public String getDescription() { return description; }
+ public DataScope getScope() { return scope; }
+ public JsonNode getSchemaJson() { return schemaJson; }
+ public String getSchemaVersion() { return schemaVersion; }
+ public String getBundle() { return bundle; }
+ public String[] getSupportedLocales() { return supportedLocales; }
+ public String getDefaultLocale() { return defaultLocale; }
+ public OffsetDateTime getCreatedAt() { return createdAt; }
+ public OffsetDateTime getUpdatedAt() { return updatedAt; }
+ public String getCreatedBy() { return createdBy; }
+ public String getUpdatedBy() { return updatedBy; }
+ public Long getVersion() { return version; }
+
+ public void setDisplayName(String v) { this.displayName = v; }
+ public void setDescription(String v) { this.description = v; }
+ public void setSchemaJson(JsonNode v) { this.schemaJson = v; }
+ public void setSchemaVersion(String v) { this.schemaVersion = v; }
+ public void setBundle(String v) { this.bundle = v; }
+ public void setSupportedLocales(String[] v) { this.supportedLocales = v; }
+ public void setDefaultLocale(String v) { this.defaultLocale = v; }
+}
diff --git a/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/definition/DictionaryDefinitionRepository.java b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/definition/DictionaryDefinitionRepository.java
new file mode 100644
index 0000000..10343dc
--- /dev/null
+++ b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/definition/DictionaryDefinitionRepository.java
@@ -0,0 +1,19 @@
+package cloud.nstart.terravault.ordinis.domain.definition;
+
+import cloud.nstart.terravault.ordinis.domain.DataScope;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.List;
+import java.util.Optional;
+import java.util.UUID;
+
+public interface DictionaryDefinitionRepository extends JpaRepository {
+
+ Optional findByName(String name);
+
+ List findByBundle(String bundle);
+
+ List findByScope(DataScope scope);
+
+ boolean existsByName(String name);
+}
diff --git a/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/idempotency/IdempotencyKey.java b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/idempotency/IdempotencyKey.java
new file mode 100644
index 0000000..7270974
--- /dev/null
+++ b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/idempotency/IdempotencyKey.java
@@ -0,0 +1,63 @@
+package cloud.nstart.terravault.ordinis.domain.idempotency;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import io.hypersistence.utils.hibernate.type.json.JsonType;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import org.hibernate.annotations.Type;
+
+import java.time.OffsetDateTime;
+
+/**
+ * Idempotency key для exactly-once семантики write API. Header
+ * {@code Idempotency-Key} от клиента кладётся сюда вместе с request hash и
+ * сохранённым response. На повторный запрос с тем же ключом возвращается тот
+ * же ответ, не повторяется side-effect (запись + outbox event).
+ */
+@Entity
+@Table(name = "idempotency_keys")
+public class IdempotencyKey {
+
+ @Id
+ @Column(name = "key", nullable = false, length = 128)
+ private String key;
+
+ @Column(name = "request_hash", nullable = false, length = 64)
+ private String requestHash;
+
+ @Column(name = "response_status")
+ private Integer responseStatus;
+
+ @Type(JsonType.class)
+ @Column(name = "response_body", columnDefinition = "jsonb")
+ private JsonNode responseBody;
+
+ @Column(name = "created_at", nullable = false)
+ private OffsetDateTime createdAt;
+
+ @Column(name = "expires_at", nullable = false)
+ private OffsetDateTime expiresAt;
+
+ protected IdempotencyKey() {}
+
+ public IdempotencyKey(String key, String requestHash, OffsetDateTime expiresAt) {
+ this.key = key;
+ this.requestHash = requestHash;
+ this.createdAt = OffsetDateTime.now();
+ this.expiresAt = expiresAt;
+ }
+
+ public String getKey() { return key; }
+ public String getRequestHash() { return requestHash; }
+ public Integer getResponseStatus() { return responseStatus; }
+ public JsonNode getResponseBody() { return responseBody; }
+ public OffsetDateTime getCreatedAt() { return createdAt; }
+ public OffsetDateTime getExpiresAt() { return expiresAt; }
+
+ public void setResponse(int status, JsonNode body) {
+ this.responseStatus = status;
+ this.responseBody = body;
+ }
+}
diff --git a/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/idempotency/IdempotencyKeyRepository.java b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/idempotency/IdempotencyKeyRepository.java
new file mode 100644
index 0000000..b5aa795
--- /dev/null
+++ b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/idempotency/IdempotencyKeyRepository.java
@@ -0,0 +1,17 @@
+package cloud.nstart.terravault.ordinis.domain.idempotency;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.time.OffsetDateTime;
+
+public interface IdempotencyKeyRepository extends JpaRepository {
+
+ @Modifying
+ @Transactional
+ @Query("DELETE FROM IdempotencyKey k WHERE k.expiresAt < :now")
+ int deleteExpired(@Param("now") OffsetDateTime now);
+}
diff --git a/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/outbox/OutboxEvent.java b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/outbox/OutboxEvent.java
new file mode 100644
index 0000000..fd74254
--- /dev/null
+++ b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/outbox/OutboxEvent.java
@@ -0,0 +1,125 @@
+package cloud.nstart.terravault.ordinis.domain.outbox;
+
+import cloud.nstart.terravault.ordinis.domain.DataScope;
+import com.fasterxml.jackson.databind.JsonNode;
+import io.hypersistence.utils.hibernate.type.json.JsonType;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.EnumType;
+import jakarta.persistence.Enumerated;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import org.hibernate.annotations.Type;
+
+import java.time.OffsetDateTime;
+
+/**
+ * Outbox row для надёжной публикации в Kafka. Записывается в той же транзакции
+ * что и dictionary_records change. {@code @Scheduled} poller (`ordinis-outbox`)
+ * читает unpublished, отправляет в правильный scope-топик, помечает published_at.
+ */
+@Entity
+@Table(name = "outbox_events")
+public class OutboxEvent {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "id")
+ private Long id;
+
+ @Column(name = "event_type", nullable = false, length = 64)
+ private String eventType;
+
+ @Column(name = "aggregate_type", nullable = false, length = 64)
+ private String aggregateType;
+
+ @Column(name = "aggregate_id", nullable = false, length = 256)
+ private String aggregateId;
+
+ @Column(name = "dictionary_name", length = 128)
+ private String dictionaryName;
+
+ @Enumerated(EnumType.STRING)
+ @Column(name = "data_scope", nullable = false, length = 32)
+ private DataScope dataScope;
+
+ @Type(JsonType.class)
+ @Column(name = "payload", nullable = false, columnDefinition = "jsonb")
+ private JsonNode payload;
+
+ @Column(name = "kafka_topic", nullable = false, length = 256)
+ private String kafkaTopic;
+
+ @Column(name = "kafka_key", nullable = false, length = 512)
+ private String kafkaKey;
+
+ @Column(name = "created_at", nullable = false)
+ private OffsetDateTime createdAt;
+
+ @Column(name = "published_at")
+ private OffsetDateTime publishedAt;
+
+ @Column(name = "trace_id", length = 64)
+ private String traceId;
+
+ @Column(name = "span_id", length = 64)
+ private String spanId;
+
+ @Column(name = "attempt_count", nullable = false)
+ private Integer attemptCount = 0;
+
+ @Column(name = "last_error", columnDefinition = "TEXT")
+ private String lastError;
+
+ protected OutboxEvent() {}
+
+ public OutboxEvent(
+ String eventType,
+ String aggregateType,
+ String aggregateId,
+ DataScope dataScope,
+ JsonNode payload,
+ String kafkaTopic,
+ String kafkaKey) {
+ this.eventType = eventType;
+ this.aggregateType = aggregateType;
+ this.aggregateId = aggregateId;
+ this.dataScope = dataScope;
+ this.payload = payload;
+ this.kafkaTopic = kafkaTopic;
+ this.kafkaKey = kafkaKey;
+ this.createdAt = OffsetDateTime.now();
+ }
+
+ public void markPublished() {
+ this.publishedAt = OffsetDateTime.now();
+ this.lastError = null;
+ }
+
+ public void markFailed(String error) {
+ this.attemptCount = (this.attemptCount == null ? 0 : this.attemptCount) + 1;
+ this.lastError = error;
+ }
+
+ public Long getId() { return id; }
+ public String getEventType() { return eventType; }
+ public String getAggregateType() { return aggregateType; }
+ public String getAggregateId() { return aggregateId; }
+ public String getDictionaryName() { return dictionaryName; }
+ public DataScope getDataScope() { return dataScope; }
+ public JsonNode getPayload() { return payload; }
+ public String getKafkaTopic() { return kafkaTopic; }
+ public String getKafkaKey() { return kafkaKey; }
+ public OffsetDateTime getCreatedAt() { return createdAt; }
+ public OffsetDateTime getPublishedAt() { return publishedAt; }
+ public String getTraceId() { return traceId; }
+ public String getSpanId() { return spanId; }
+ public Integer getAttemptCount() { return attemptCount; }
+ public String getLastError() { return lastError; }
+
+ public void setDictionaryName(String v) { this.dictionaryName = v; }
+ public void setTraceId(String v) { this.traceId = v; }
+ public void setSpanId(String v) { this.spanId = v; }
+}
diff --git a/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/outbox/OutboxEventRepository.java b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/outbox/OutboxEventRepository.java
new file mode 100644
index 0000000..0fc740b
--- /dev/null
+++ b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/outbox/OutboxEventRepository.java
@@ -0,0 +1,18 @@
+package cloud.nstart.terravault.ordinis.domain.outbox;
+
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+
+import java.util.List;
+
+public interface OutboxEventRepository extends JpaRepository {
+
+ /**
+ * Unpublished events для polling. Использует partial index {@code idx_outbox_unpublished}.
+ */
+ @Query("SELECT o FROM OutboxEvent o WHERE o.publishedAt IS NULL ORDER BY o.id ASC")
+ List findUnpublished(Pageable pageable);
+
+ long countByPublishedAtIsNull();
+}
diff --git a/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/record/DictionaryRecord.java b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/record/DictionaryRecord.java
new file mode 100644
index 0000000..b0405e0
--- /dev/null
+++ b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/record/DictionaryRecord.java
@@ -0,0 +1,133 @@
+package cloud.nstart.terravault.ordinis.domain.record;
+
+import cloud.nstart.terravault.ordinis.domain.DataScope;
+import com.fasterxml.jackson.databind.JsonNode;
+import io.hypersistence.utils.hibernate.type.json.JsonType;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.EntityListeners;
+import jakarta.persistence.EnumType;
+import jakarta.persistence.Enumerated;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import jakarta.persistence.Version;
+import org.hibernate.annotations.JdbcTypeCode;
+import org.hibernate.annotations.Type;
+import org.hibernate.envers.Audited;
+import org.hibernate.envers.RelationTargetAuditMode;
+import org.hibernate.type.SqlTypes;
+import org.locationtech.jts.geom.Geometry;
+import org.springframework.data.annotation.CreatedBy;
+import org.springframework.data.annotation.CreatedDate;
+import org.springframework.data.annotation.LastModifiedBy;
+import org.springframework.data.annotation.LastModifiedDate;
+import org.springframework.data.jpa.domain.support.AuditingEntityListener;
+
+import java.time.OffsetDateTime;
+import java.util.UUID;
+
+/**
+ * Bitemporal entity справочной записи.
+ *
+ * Две оси истории:
+ *
+ * - Transaction time — Hibernate Envers ({@code @Audited}). Когда мы
+ * знали о факте.
+ * - Effective time — {@code valid_from}/{@code valid_to}. Когда факт
+ * действует (например запись действует с 2027-01-01 но введена сегодня).
+ *
+ *
+ * EXCLUSION CONSTRAINT в БД (см. Liquibase 0003) гарантирует отсутствие overlap
+ * по {@code (dictionary_id, business_key, valid_from..valid_to)}.
+ */
+@Entity
+@Table(name = "dictionary_records")
+@Audited(targetAuditMode = RelationTargetAuditMode.NOT_AUDITED)
+@EntityListeners(AuditingEntityListener.class)
+public class DictionaryRecord {
+
+ @Id
+ @Column(name = "id", nullable = false, updatable = false)
+ private UUID id;
+
+ @Column(name = "dictionary_id", nullable = false)
+ private UUID dictionaryId;
+
+ @Column(name = "business_key", nullable = false, length = 256)
+ private String businessKey;
+
+ @Type(JsonType.class)
+ @Column(name = "data", nullable = false, columnDefinition = "jsonb")
+ private JsonNode data;
+
+ @JdbcTypeCode(SqlTypes.GEOMETRY)
+ @Column(name = "geometry", columnDefinition = "geometry(Geometry, 4326)")
+ private Geometry geometry;
+
+ @Enumerated(EnumType.STRING)
+ @Column(name = "data_scope", nullable = false, length = 32)
+ private DataScope dataScope;
+
+ @Column(name = "valid_from", nullable = false)
+ private OffsetDateTime validFrom;
+
+ @Column(name = "valid_to", nullable = false)
+ private OffsetDateTime validTo = OffsetDateTime.parse("9999-12-31T23:59:59Z");
+
+ @CreatedDate
+ @Column(name = "created_at", nullable = false, updatable = false)
+ private OffsetDateTime createdAt;
+
+ @LastModifiedDate
+ @Column(name = "updated_at", nullable = false)
+ private OffsetDateTime updatedAt;
+
+ @CreatedBy
+ @Column(name = "created_by", length = 128, updatable = false)
+ private String createdBy;
+
+ @LastModifiedBy
+ @Column(name = "updated_by", length = 128)
+ private String updatedBy;
+
+ @Version
+ @Column(name = "version")
+ private Long version;
+
+ protected DictionaryRecord() {}
+
+ public DictionaryRecord(
+ UUID id,
+ UUID dictionaryId,
+ String businessKey,
+ JsonNode data,
+ DataScope dataScope,
+ OffsetDateTime validFrom) {
+ this.id = id;
+ this.dictionaryId = dictionaryId;
+ this.businessKey = businessKey;
+ this.data = data;
+ this.dataScope = dataScope;
+ this.validFrom = validFrom;
+ }
+
+ public UUID getId() { return id; }
+ public UUID getDictionaryId() { return dictionaryId; }
+ public String getBusinessKey() { return businessKey; }
+ public JsonNode getData() { return data; }
+ public Geometry getGeometry() { return geometry; }
+ public DataScope getDataScope() { return dataScope; }
+ public OffsetDateTime getValidFrom() { return validFrom; }
+ public OffsetDateTime getValidTo() { return validTo; }
+ public OffsetDateTime getCreatedAt() { return createdAt; }
+ public OffsetDateTime getUpdatedAt() { return updatedAt; }
+ public String getCreatedBy() { return createdBy; }
+ public String getUpdatedBy() { return updatedBy; }
+ public Long getVersion() { return version; }
+
+ public void setData(JsonNode v) { this.data = v; }
+ public void setGeometry(Geometry v) { this.geometry = v; }
+ public void setValidFrom(OffsetDateTime v) { this.validFrom = v; }
+ public void setValidTo(OffsetDateTime v) { this.validTo = v; }
+ public void setDataScope(DataScope v) { this.dataScope = v; }
+}
diff --git a/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/record/DictionaryRecordRepository.java b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/record/DictionaryRecordRepository.java
new file mode 100644
index 0000000..97be205
--- /dev/null
+++ b/ordinis-domain/src/main/java/cloud/nstart/terravault/ordinis/domain/record/DictionaryRecordRepository.java
@@ -0,0 +1,51 @@
+package cloud.nstart.terravault.ordinis.domain.record;
+
+import cloud.nstart.terravault.ordinis.domain.DataScope;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+import java.time.OffsetDateTime;
+import java.util.List;
+import java.util.Optional;
+import java.util.UUID;
+
+public interface DictionaryRecordRepository extends JpaRepository {
+
+ /**
+ * Все версии записи по бизнес-ключу (включая прошлые и будущие). Sorted by valid_from desc.
+ */
+ List findByDictionaryIdAndBusinessKeyOrderByValidFromDesc(
+ UUID dictionaryId, String businessKey);
+
+ /**
+ * Активная версия в момент {@code at}. Использует EXCLUSION CONSTRAINT — гарантировано не больше одной.
+ */
+ @Query("""
+ SELECT r FROM DictionaryRecord r
+ WHERE r.dictionaryId = :dictionaryId
+ AND r.businessKey = :businessKey
+ AND r.validFrom <= :at
+ AND r.validTo > :at
+ """)
+ Optional findActiveAt(
+ @Param("dictionaryId") UUID dictionaryId,
+ @Param("businessKey") String businessKey,
+ @Param("at") OffsetDateTime at);
+
+ /**
+ * Все активные записи в справочнике в момент {@code at}, отфильтрованные по доступным scope'ам
+ * для consumer'а. Используется read-api после locale negotiation.
+ */
+ @Query("""
+ SELECT r FROM DictionaryRecord r
+ WHERE r.dictionaryId = :dictionaryId
+ AND r.dataScope IN :allowedScopes
+ AND r.validFrom <= :at
+ AND r.validTo > :at
+ """)
+ List findActiveByDictionaryAndScopes(
+ @Param("dictionaryId") UUID dictionaryId,
+ @Param("allowedScopes") List allowedScopes,
+ @Param("at") OffsetDateTime at);
+}
diff --git a/ordinis-events-api/pom.xml b/ordinis-events-api/pom.xml
index 56406e2..fe2501d 100644
--- a/ordinis-events-api/pom.xml
+++ b/ordinis-events-api/pom.xml
@@ -19,5 +19,9 @@
com.fasterxml.jackson.core
jackson-annotations