This commit is contained in:
parent
51e6bb05c9
commit
6d582efa16
1 changed files with 3 additions and 2 deletions
|
|
@ -85,7 +85,8 @@ public class MonitoringService {
|
|||
private void monitor() {
|
||||
try {
|
||||
log.info("Start monitoring");
|
||||
List<UserPackage> packages = userPackageMapper.findAllPackagesByStatus(Status.ON_MONITORING.name());
|
||||
List<UserPackage> packages = userPackageMapper.findAllPackagesByStatus(Status.ON_MONITORING.name(),
|
||||
Status.PROCESSING_REPEATED.name());
|
||||
for (UserPackage userPackage : packages) {
|
||||
MDC.put("ru.nbch.credit_tracker.log.mdc.key", "[" + userPackage.getPackageName() + "]");
|
||||
processPackage(userPackage);
|
||||
|
|
@ -103,7 +104,7 @@ public class MonitoringService {
|
|||
log.info("Package has no fids. Package will be skipped.");
|
||||
return;
|
||||
}
|
||||
SgnlOnlineReport onlineReports = signalRestService.getReports(userPackage.getUserId() + "_" + userPackage.getPackageName());
|
||||
SgnlOnlineReport onlineReports = signalRestService.getReports(userPackage.getUserId().substring(0, 6) + "_" + userPackage.getPackageName());
|
||||
|
||||
if (onlineReports == null) {
|
||||
log.info("No reports found for package");
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue