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

update flags

Browse source
This commit is contained in:
ialbert 2025-11-28 14:39:11 +03:00
parent 8000a22dd4
commit 08f7692899
2 changed files with 2 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -89,8 +89,6 @@ public class SignalService {
public UpdateResult updateFlags2(UserPackage userPackage) { public UpdateResult updateFlags2(UserPackage userPackage) {
log.debug("updating flags for package [{} {}]", userPackage.getPackageName(), userPackage.getId()); log.debug("updating flags for package [{} {}]", userPackage.getPackageName(), userPackage.getId());
boolean updated = false;
boolean noFidsFound = true;
Long packageId = userPackage.getId(); Long packageId = userPackage.getId();
int offset = 0; int offset = 0;
List<PhoneFidMap> page = phoneService2.pageByPackageId(packageId, batchSize, offset); List<PhoneFidMap> page = phoneService2.pageByPackageId(packageId, batchSize, offset);
@ -111,7 +109,7 @@ public class SignalService {
log.debug("loading next page..."); log.debug("loading next page...");
page = phoneService2.pageByPackageId(packageId, batchSize, offset); page = phoneService2.pageByPackageId(packageId, batchSize, offset);
} }
return new UpdateResult(updated, noFidsFound); return new UpdateResult(true, false);
} }
/** /**

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

@ -63,7 +63,7 @@ public class UpdatingFlagsService {
String packageName = userPackage.getPackageName(); String packageName = userPackage.getPackageName();
try { try {
signalService.updatePackageStatus(packageId, Status.PROCESSING); signalService.updatePackageStatus(packageId, Status.PROCESSING);
SignalService.UpdateResult updateResult = signalService.updateSubjects(packageId, null); SignalService.UpdateResult updateResult = signalService.updateFlags2(userPackage);
if (updateResult.isUpdated()) { if (updateResult.isUpdated()) {
if (signalRestService.setupMonitoring(packageId)) { if (signalRestService.setupMonitoring(packageId)) {
// LocalDateTime monitoringAt = userPackage.getMonitoringAt() != null ? userPackage.getMonitoringAt() : LocalDateTime.now(); // LocalDateTime monitoringAt = userPackage.getMonitoringAt() != null ? userPackage.getMonitoringAt() : LocalDateTime.now();