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

Added logs for UpdatingFlagsService

Browse source
This commit is contained in:
Mikhail Trofimov 2025-06-27 14:41:15 +03:00
parent a56d6a2712
commit f0b7149b05
1 changed files with 9 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/main/java/ru/nbch/credit_tracker/service/UpdatingFlagsService.java
View file

@ -41,25 +41,32 @@ public class UpdatingFlagsService {
}
private void update() {
log.info("Start updating flags");
List<PackageData> packages = signalService.findPackagesOnMonitoring();
for (PackageData packageData : packages) {
log.info("Updating flags for Package {}", packageData.getPackageName());
List<SubjectData> subjects = signalService.findFullSubjectsData(packageData.getId())
.stream().filter(subject -> subject.getCalculatedAt() != null && hasDaysPassed(subject.getCalculatedAt())).toList();
updateFlags(packageData.getId(), subjects);
updateFlags(packageData.getId(), subjects, packageData.getPackageName());
}
}
private void updateFlags(Integer packageId, List<SubjectData> subjects) {
private void updateFlags(Integer packageId, List<SubjectData> subjects, String packageName) {
try {
signalService.setPackageStatus(packageId, Status.PROCESSING);
List<PhoneService.FidsPhoneData> phoneFidsData = signalService.updateFlags(subjects);
if (!phoneFidsData.isEmpty()) {
Signals signals = signalService.buildSignals(packageId, phoneFidsData);
if (signalRestService.update(signals)) {
log.info("Flags were updated successfully. PackageId: {} PackageName: {}. Package status changed to ON_MONITORING", packageId, packageName);
signalService.setPackageStatus(packageId, Status.ON_MONITORING);
} else {
log.info("Updated package registration was rejected by signal service. PackageId: {} PackageName: {}", packageId, packageName);
signalService.setPackageStatus(packageId, Status.ERROR);
}
} else {
log.info("No flags were updated for package id {}. Package status changed to ON_MONITORING", packageId);
signalService.setPackageStatus(packageId, Status.ON_MONITORING);
}
} catch (Exception e) {
log.error("Ошибка при поиске фидов или перерасчете флагов просрочек. Package_id {}", packageId, e);