chore: [LOB-1806] Reconciliation indexer endpoint

Author: M4rc0Russ0

accounting_reporting_core/src/main/java/org/cardanofoundation/lob/app/accounting_reporting_core/domain/core/OnChainTransactionDto.java

@@ -0,0 +1,20 @@
+package org.cardanofoundation.lob.app.accounting_reporting_core.domain.core;
+
+import java.util.List;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public record OnChainTransactionDto(
+        @JsonProperty("id") String id,
+        @JsonProperty("tx_hash") String txHash,
+        @JsonProperty("internal_number") String internalNumber,
+        @JsonProperty("accounting_period") String accountingPeriod,
+        @JsonProperty("batch_id") String batchId,
+        @JsonProperty("type") String type,
+        @JsonProperty("date") String date,
+        @JsonProperty("organisation_id") String organisationId,
+        @JsonProperty("items") List<OnChainTransactionItemDto> items
+) {
+}

accounting_reporting_core/src/main/java/org/cardanofoundation/lob/app/accounting_reporting_core/domain/core/OnChainTransactionItemDto.java

@@ -0,0 +1,24 @@
+package org.cardanofoundation.lob.app.accounting_reporting_core.domain.core;
+
+import java.math.BigDecimal;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public record OnChainTransactionItemDto(
+        @JsonProperty("id") String id,
+        @JsonProperty("amountFcy") BigDecimal amountFcy,
+        @JsonProperty("fxRate") String fxRate,
+        @JsonProperty("documentNumber") String documentNumber,
+        @JsonProperty("currency") String currency,
+        @JsonProperty("costCenterName") String costCenterName,
+        @JsonProperty("costCenterCustCode") String costCenterCustCode,
+        @JsonProperty("vatRate") String vatRate,
+        @JsonProperty("vatCustCode") String vatCustCode,
+        @JsonProperty("eventCode") String eventCode,
+        @JsonProperty("eventName") String eventName,
+        @JsonProperty("projectCustCode") String projectCustCode,
+        @JsonProperty("projectName") String projectName
+) {
+}

accounting_reporting_core/src/main/java/org/cardanofoundation/lob/app/accounting_reporting_core/domain/entity/TransactionEntity.java

@@ -210,6 +210,7 @@ public class TransactionEntity extends CommonEntity implements Persistable<Strin
 
     @OneToOne(fetch = FetchType.LAZY)
     @JoinColumn(name = "reconcilation_id")
+    @DiffIgnore
     @Nullable
     private ReconcilationEntity lastReconcilation;
 

accounting_reporting_core/src/main/java/org/cardanofoundation/lob/app/accounting_reporting_core/domain/entity/TransactionItemEntity.java

@@ -256,4 +256,7 @@ public int hashCode() {
         return Objects.hashCode(id);
     }
 
+    public int aggregatedHash() {
+        return java.util.Objects.hash(accountEvent, fxRate, project, costCenter, document);
+    }
 }

accounting_reporting_core/src/main/java/org/cardanofoundation/lob/app/accounting_reporting_core/domain/entity/reconcilation/ReconcilationViolation.java

@@ -26,20 +26,22 @@
 @AllArgsConstructor
 @NoArgsConstructor
 @Builder
-@EqualsAndHashCode
+@EqualsAndHashCode(onlyExplicitlyIncluded = true)
 @Audited
 public class ReconcilationViolation {
 
     @NotBlank
     @Getter
     @Setter
+    @EqualsAndHashCode.Include
     private String transactionId;
 
     @NotNull
     @Enumerated(STRING)
     @Getter
     @Setter
     @JdbcType(PostgreSQLEnumJdbcType.class)
+    @EqualsAndHashCode.Include
     private ReconcilationRejectionCode rejectionCode;
 
     @Type(value = io.hypersistence.utils.hibernate.type.json.JsonType.class)

accounting_reporting_core/src/main/java/org/cardanofoundation/lob/app/accounting_reporting_core/repository/AccountingCoreTransactionRepository.java

@@ -41,6 +41,17 @@ Set<TransactionEntity> findByEntryDateRangeAndNotReconciledYet(@Param("organisat
                                               @Param("startDate") LocalDate startDate,
                                               @Param("endDate") LocalDate endDate);
 
+    @Query("""
+            SELECT t FROM accounting_reporting_core.TransactionEntity t
+            WHERE t.organisation.id = :organisationId
+            AND t.entryDate BETWEEN :startDate AND :endDate
+            ORDER BY t.createdAt ASC, t.id ASC
+            """)
+    Set<TransactionEntity> findByEntryDateRange(@Param("organisationId") String organisactionId,
+                                                                   @Param("startDate") LocalDate startDate,
+                                                                   @Param("endDate") LocalDate endDate);
+
+
     @Query("""
         SELECT t FROM accounting_reporting_core.TransactionEntity t
         WHERE t.organisation.id = :organisationId

accounting_reporting_core/src/main/java/org/cardanofoundation/lob/app/accounting_reporting_core/repository/TransactionReconcilationRepository.java

@@ -2,11 +2,17 @@
 
 import java.util.Optional;
 
+import jakarta.persistence.LockModeType;
+
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Lock;
 
 import org.cardanofoundation.lob.app.accounting_reporting_core.domain.entity.reconcilation.ReconcilationEntity;
 
 public interface TransactionReconcilationRepository extends JpaRepository<ReconcilationEntity, String> {
 
     Optional<ReconcilationEntity> findTopByOrderByCreatedAtDesc();
+
+    @Lock(LockModeType.PESSIMISTIC_WRITE)
+    Optional<ReconcilationEntity> findReconcilationEntityById(String id);
 }

accounting_reporting_core/src/main/java/org/cardanofoundation/lob/app/accounting_reporting_core/resource/requests/OnChainTransactionSearchRequest.java

@@ -0,0 +1,10 @@
+package org.cardanofoundation.lob.app.accounting_reporting_core.resource.requests;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+public record OnChainTransactionSearchRequest(
+        @JsonProperty("organisationId") String organisationId,
+        @JsonProperty("dateFrom") String dateFrom,
+        @JsonProperty("dateTo") String dateTo
+) {
+}

accounting_reporting_core/src/main/java/org/cardanofoundation/lob/app/accounting_reporting_core/resource/response/OnChainTransactionsPageResponse.java

@@ -0,0 +1,21 @@
+package org.cardanofoundation.lob.app.accounting_reporting_core.resource.response;
+
+import java.util.List;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import org.cardanofoundation.lob.app.accounting_reporting_core.domain.core.OnChainTransactionDto;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public record OnChainTransactionsPageResponse(
+        @JsonProperty("content") List<OnChainTransactionDto> content,
+        @JsonProperty("total_elements") long totalElements,
+        @JsonProperty("total_pages") int totalPages,
+        @JsonProperty("last") boolean last,
+        @JsonProperty("size") int size,
+        @JsonProperty("number") int number,
+        @JsonProperty("first") boolean first,
+        @JsonProperty("empty") boolean empty
+) {
+}

accounting_reporting_core/src/main/java/org/cardanofoundation/lob/app/accounting_reporting_core/service/internal/AccountingCoreEventHandler.java

@@ -27,10 +27,7 @@
 import org.cardanofoundation.lob.app.accounting_reporting_core.domain.event.extraction.ValidateIngestionResponseEvent;
 import org.cardanofoundation.lob.app.accounting_reporting_core.domain.event.ledger.ReportsLedgerUpdatedEvent;
 import org.cardanofoundation.lob.app.accounting_reporting_core.domain.event.ledger.TxsLedgerUpdatedEvent;
-import org.cardanofoundation.lob.app.accounting_reporting_core.domain.event.reconcilation.ReconcilationChunkEvent;
-import org.cardanofoundation.lob.app.accounting_reporting_core.domain.event.reconcilation.ReconcilationFailedEvent;
-import org.cardanofoundation.lob.app.accounting_reporting_core.domain.event.reconcilation.ReconcilationFinalisationEvent;
-import org.cardanofoundation.lob.app.accounting_reporting_core.domain.event.reconcilation.ReconcilationStartedEvent;
+import org.cardanofoundation.lob.app.accounting_reporting_core.domain.event.reconcilation.*;
 import org.cardanofoundation.lob.app.accounting_reporting_core.job.TxStatusUpdaterJob;
 import org.cardanofoundation.lob.app.accounting_reporting_core.service.ValidateIngestionResponseWaiter;
 import org.cardanofoundation.lob.app.accounting_reporting_core.service.business_rules.ProcessorFlags;