@@ -9,7 +9,6 @@ import org.springframework.transaction.annotation.Transactional;
|
|||||||
import ru.soune.nocopy.entity.monitoring.FileMonitoringEntity;
|
import ru.soune.nocopy.entity.monitoring.FileMonitoringEntity;
|
||||||
import ru.soune.nocopy.repository.FileMonitoringRepository;
|
import ru.soune.nocopy.repository.FileMonitoringRepository;
|
||||||
import ru.soune.nocopy.service.monitoring.MonitoringSearchService;
|
import ru.soune.nocopy.service.monitoring.MonitoringSearchService;
|
||||||
import ru.soune.nocopy.service.tariff.TariffInfoService;
|
|
||||||
|
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|||||||
@@ -48,7 +48,7 @@ public class MonitoringSearchService {
|
|||||||
|
|
||||||
private final SearchProperties searchProperties;
|
private final SearchProperties searchProperties;
|
||||||
|
|
||||||
@Transactional
|
@Transactional(noRollbackFor = TariffNotFoundException.class)
|
||||||
public void processFileSearch(FileMonitoringEntity monitoring) throws MessagingException, IOException {
|
public void processFileSearch(FileMonitoringEntity monitoring) throws MessagingException, IOException {
|
||||||
monitoring.setLastRun(LocalDateTime.now());
|
monitoring.setLastRun(LocalDateTime.now());
|
||||||
monitoring.setLastRunStatus("IN_PROGRESS");
|
monitoring.setLastRunStatus("IN_PROGRESS");
|
||||||
@@ -141,8 +141,6 @@ public class MonitoringSearchService {
|
|||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
log.error("Error processing monitoring search", e);
|
log.error("Error processing monitoring search", e);
|
||||||
monitoring.setLastRunStatus("ERROR: " + e.getMessage());
|
monitoring.setLastRunStatus("ERROR: " + e.getMessage());
|
||||||
|
|
||||||
} finally {
|
|
||||||
updateNextRun(monitoring);
|
updateNextRun(monitoring);
|
||||||
monitoringRepository.save(monitoring);
|
monitoringRepository.save(monitoring);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user