src/main/java/ru/ulstu/extractor/assessment/controller/AssessmentController.java

@@ -27,7 +27,7 @@ public class AssessmentController {
 
     @GetMapping(ASSESSMENTS)
     public String getAssessments(Model model, @RequestParam Optional<Integer> branchId) {
-        model.addAttribute("branches", branchService.findAllValid());
+        model.addAttribute("branches", branchService.findAll());
         if (branchId.isPresent()) {
             model.addAttribute("assessments", assessmentService.getAssessmentsByForecastTendencies(branchId.get()));
             model.addAttribute("filterBranchForm", new FilterBranchForm(branchId.get()));

src/main/java/ru/ulstu/extractor/assessment/service/AssessmentService.java

@@ -54,7 +54,9 @@ public class AssessmentService {
 
     private List<Assessment> getSingleAssessmentByTimeSeriesTendencies(List<DbRule> dbRules, List<TimeSeries> timeSeries) throws AssessmentException {
         Map<String, Double> variableValues = new HashMap<>();
-        timeSeries.forEach(ts -> variableValues.put(ts.getTimeSeriesType().name(), timeSeriesService.getLastTimeSeriesTendency(ts)));
+        timeSeries.forEach(ts -> variableValues.put(ts.getTimeSeriesType().name(),
+                timeSeriesService.getLastTimeSeriesTendency(ts)
+                        .orElseThrow(() -> new AssessmentException(""))));
         return fuzzyInferenceService.getFuzzyInference(dbRules,
                 antecedentValueService.getList(),
                 variableValues,
@@ -72,7 +74,8 @@ public class AssessmentService {
                             .filter(ts -> ts.getTimeSeriesType() == dbRule.getFirstAntecedent()
                                     || ts.getTimeSeriesType() == dbRule.getSecondAntecedent())
                             .forEach(ts -> variableValues.put(ts.getTimeSeriesType().name(), timeSeriesService
-                                    .getLastTimeSeriesTendency(ts)));
+                                    .getLastTimeSeriesTendency(ts)
+                                    .orElse(ts.getValues().get(ts.getValues().size() - 1).getValue())));
                     return fuzzyInferenceService.getFuzzyInference(List.of(dbRule),
                             antecedentValueService.getList(),
                             variableValues,

src/main/java/ru/ulstu/extractor/branch/service/BranchService.java

@@ -16,7 +16,6 @@ import ru.ulstu.extractor.commit.model.Commit;
 import ru.ulstu.extractor.commit.service.CommitService;
 import ru.ulstu.extractor.core.BaseEntity;
 import ru.ulstu.extractor.gitrepository.model.GitRepository;
-import ru.ulstu.extractor.ts.service.TimeSeriesService;
 
 import java.util.List;
 import java.util.Optional;
@@ -27,14 +26,11 @@ public class BranchService {
     private final static Logger LOG = LoggerFactory.getLogger(BranchService.class);
     private final BranchRepository branchRepository;
     private final CommitService commitService;
-    private final TimeSeriesService timeSeriesService;
 
     public BranchService(BranchRepository branchRepository,
-                         CommitService commitService,
+                         CommitService commitService) {
-                         TimeSeriesService timeSeriesService) {
         this.branchRepository = branchRepository;
         this.commitService = commitService;
-        this.timeSeriesService = timeSeriesService;
     }
 
     @Transactional
@@ -91,11 +87,4 @@ public class BranchService {
         branch.setIndexingStatus(indexingStatus);
         return branchRepository.save(branch);
     }
-
-    public List<Branch> findAllValid() {
-        return findAll()
-                .stream()
-                .filter(timeSeriesService::isBranchContainsAllTimeSeries)
-                .collect(Collectors.toList());
-    }
 }

src/main/java/ru/ulstu/extractor/ts/service/TimeSeriesService.java

@@ -1,3 +1,8 @@
+/*
+ * Copyright (C) 2021 Anton Romanov - All Rights Reserved
+ * You may use, distribute and modify this code, please write to: romanov73@gmail.com.
+ */
+
 package ru.ulstu.extractor.ts.service;
 
 import org.json.JSONArray;
@@ -23,13 +28,10 @@ import java.util.Arrays;
 import java.util.List;
 import java.util.Optional;
 import java.util.stream.Collectors;
-import java.util.stream.Stream;
 
 @Service
 public class TimeSeriesService {
     private final static Logger LOG = LoggerFactory.getLogger(TimeSeriesService.class);
-    private final static int MIN_TIME_SERIES_LENGTH = 5;
-    private final static double DEFAULT_TIME_SERIES_TENDENCY = 0.0;
     private final TimeSeriesRepository timeSeriesRepository;
     private final TimeSeriesValueRepository timeSeriesValueRepository;
     private final TimeSeriesDateMapper.TimeSeriesInterval timeSeriesInterval = TimeSeriesDateMapper.TimeSeriesInterval.HOUR;
@@ -125,24 +127,17 @@ public class TimeSeriesService {
         return timeSeriesRepository.getTimeSeriesByBranchId(branchId);
     }
 
-    public double getLastTimeSeriesTendency(TimeSeries ts) {
+    public Optional<Double> getLastTimeSeriesTendency(TimeSeries ts) {
-        if (ts != null && ts.getValues().size() > MIN_TIME_SERIES_LENGTH) {
+        if (ts != null && ts.getValues().size() > 5) {
             JSONObject response = httpService.post(TIME_SERIES_TENDENCY_URL, new JSONObject(new SmoothingTimeSeries(ts)));
             LOG.debug("Успешно отправлен на сервис сглаживания");
             if (response.has("response") && response.getString("response").equals("empty")) {
-                return DEFAULT_TIME_SERIES_TENDENCY;
+                return Optional.empty();
             }
             JSONArray jsonArray = response.getJSONObject("timeSeries").getJSONArray("values");
-            return jsonArray.getJSONObject(jsonArray.length() - 1).getDouble("value");
+            return Optional.of(jsonArray.getJSONObject(jsonArray.length() - 1).getDouble("value"));
         }
-        return DEFAULT_TIME_SERIES_TENDENCY;
+        return Optional.empty();
-    }
-
-    public boolean isBranchContainsAllTimeSeries(Branch b) {
-        List<TimeSeries> timeSeries = getByBranch(b.getId());
-        return Stream.of(TimeSeriesType.values()).allMatch(type -> timeSeries
-                .stream()
-                .anyMatch(ts -> type == ts.getTimeSeriesType()));
     }
 
     public List<TimeSeries> getGroupedTendencies(List<TimeSeries> tsList) {