treshenkov/credit_tracker
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix empty inserting while registering subjects; Update version to 1.5

Browse source
This commit is contained in:
Mikhail Trofimov 2025-09-03 15:42:36 +03:00
parent 9ce3b91a1e
commit af2cd72647
3 changed files with 9 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
pom.xml
View file

@ -10,7 +10,7 @@
</parent> </parent>
<groupId>ru.nbch</groupId> <groupId>ru.nbch</groupId>
<artifactId>credit-tracker</artifactId> <artifactId>credit-tracker</artifactId>
<version>1.4</version> <version>1.5</version>
<name>credit_tracker</name> <name>credit_tracker</name>
<description>Credit Tracker Application</description> <description>Credit Tracker Application</description>

4
src/main/java/ru/nbch/credit_tracker/service/MonitoringService.java
View file

@ -261,7 +261,9 @@ public class MonitoringService {
hit.setReportFileName(reportFileName); hit.setReportFileName(reportFileName);
hits.add(hit); hits.add(hit);
}); });
signalService.insertHits(hits); if (!hits.isEmpty()) {
signalService.insertHits(hits);
}
}); });
response.getSubjects().getSubjects().clear(); // чистим список для экономии памяти response.getSubjects().getSubjects().clear(); // чистим список для экономии памяти
}, },

8
src/main/java/ru/nbch/credit_tracker/service/SignalService.java
View file

@ -86,9 +86,11 @@ public class SignalService {
try (BufferedInputStream in = new BufferedInputStream(Files.newInputStream(Path.of(filePath)), 8 * 1024 * 1024)) { try (BufferedInputStream in = new BufferedInputStream(Files.newInputStream(Path.of(filePath)), 8 * 1024 * 1024)) {
staxXmlProcessor.read(in, MonitoringRequest.class, staxXmlProcessor.read(in, MonitoringRequest.class,
request -> { request -> {
phoneFidMapService.registerSubjects(request.getSubjects().getSubject(), packageId); if (!request.getSubjects().getSubject().isEmpty()) {
log.trace("Registered subject's batch. Total count: {}. PackageId: {}", request.getSubjects().getSubject().size(), packageId); phoneFidMapService.registerSubjects(request.getSubjects().getSubject(), packageId);
request.getSubjects().getSubject().clear(); log.trace("Registered subject's batch. Total count: {}. PackageId: {}", request.getSubjects().getSubject().size(), packageId);
request.getSubjects().getSubject().clear();
}
}, batchSize, "/MonitoringRequest/Subjects/Subject"); }, batchSize, "/MonitoringRequest/Subjects/Subject");
} catch (IOException e) { } catch (IOException e) {
throw new RuntimeException("Error while parsing monitoring request", e); throw new RuntimeException("Error while parsing monitoring request", e);