valitydev/exporter-tech-metrics
14
0
Fork 0
mirror of https://github.com/valitydev/exporter-tech-metrics.git synced 2024-11-06 00:15:21 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fixing finding withdrawal data (#19)

Browse Source 
* Fixing finding withdrawal data

* Fixing regex for withdrawalId

* Fixing logging machines failed data

* Fixing regex for machines failed ids
This commit is contained in:
Gretchen-z 2024-08-02 14:19:46 +03:00 committed by GitHub
parent 1218eec297
commit bce403a169
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 12 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/main/java/dev/vality/exporter/tech/metrics/service/MachinesFailedService.java
View File

@ -28,6 +28,7 @@ public class MachinesFailedService {
private final Map<String, Double> machinesFailedCountMap;
private static final String WITHDRAWAL = "withdrawal";
private static final String INVOICE = "invoice";
private static final String AFTER_SLASH = "/\\d+$";
public void registerMetrics() {
@ -41,14 +42,13 @@ public class MachinesFailedService {
var withdrawalIds = machinesFailedData.stream()
.filter(w -> w.getMachineNs().contains(WITHDRAWAL))
.map(MachinesFailedData::getMachineId)
.collect(Collectors.collectingAndThen(
Collectors.toList(),
list -> log.isDebugEnabled()
? list.stream().limit(10).collect(Collectors.toList()) : list
));
log.debug("withdrawalIds {}", withdrawalIds);
.map(id -> id.replaceAll(AFTER_SLASH, ""))
.toList();
log.debug("withdrawalIds size {}, first 10 withdrawalIds {}", withdrawalIds.size(),
withdrawalIds.stream().limit(10).collect(Collectors.toList()));
var withdrawalEntities = withdrawalRepository.getWithdrawalsMetrics(withdrawalIds);
log.debug("withdrawalEntities {}", withdrawalEntities);
log.debug("withdrawalEntities size {}, first 10 withdrawalEntities {}", withdrawalEntities.size(),
withdrawalEntities.stream().limit(10).collect(Collectors.toList()));
var withdrawalAggregatedByMachineId = withdrawalEntities.stream()
.collect(Collectors.toMap(WithdrawalsAggregatedMetricDto::getWithdrawalId,
@ -71,14 +71,12 @@ public class MachinesFailedService {
var invoiceIds = machinesFailedData.stream()
.filter(i -> i.getMachineNs().contains(INVOICE))
.map(MachinesFailedData::getMachineId)
.collect(Collectors.collectingAndThen(
Collectors.toList(),
list -> log.isDebugEnabled()
? list.stream().limit(10).collect(Collectors.toList()) : list
));
log.debug("invoiceIds {}", invoiceIds);
.toList();
log.debug("invoiceIds size {}, first 10 invoiceIds {}", invoiceIds.size(),
invoiceIds.stream().limit(10).collect(Collectors.toList()));
var invoiceEntities = paymentRepository.getPaymentsStatusMetrics(invoiceIds);
log.debug("invoiceEntities {}", invoiceEntities);
log.debug("invoiceEntities size {}, first 10 invoiceEntities {}", invoiceEntities,
invoiceEntities.stream().limit(10).collect(Collectors.toList()));
var invoiceAggregatedByMachineId = invoiceEntities.stream()
.collect(Collectors.toMap(PaymentsAggregatedMetricDto::getInvoiceId,