logging scheduled tasks process time

Author: ViLsonCake

telegram-bot/src/main/java/project/vilsoncake/telegrambot/bot/ScheduleSender.java

@@ -53,13 +53,16 @@ public class ScheduleSender {
     private final AircraftUtils aircraftUtils;
     private final List<Map<String, List<String>>> aircraftFamiliesCodes;
     private final UnitsUtils unitsUtils;
+    private final LoggingUtils loggingUtils;
     private final WebClient apiWebClient;
     private final BotSender botSender;
 
     @Transactional
     @Scheduled(fixedDelay = SCHEDULED_FLIGHTS_CHECK_DELAY_IN_MINUTES, timeUnit = TimeUnit.MINUTES)
     public void sendNewScheduledAndLiveWideBodyFlights() throws InterruptedException {
-        log.info("Schedule sending wide body flights started...");
+        log.info("Schedule sending wide-body flights started...");
+
+        long startTime = System.currentTimeMillis();
 
         List<String> uniqueAirports = userService.findUniqueAirports();
         Map<String, FlightsDto> uniqueAirportsFlights = new HashMap<>();
@@ -165,14 +168,19 @@ public void sendNewScheduledAndLiveWideBodyFlights() throws InterruptedException
                 }
             }
         }
-        log.info("Schedule sending wide body flights finished.");
+
+        long endTime = System.currentTimeMillis();
+
+        log.info("Schedule sending wide-body flights finished. {}", loggingUtils.getFinishedProcessTime(startTime, endTime));
     }
 
     @Transactional
     @Scheduled(fixedDelay = LANDING_FLIGHTS_CHECK_DELAY_IN_MINUTES, timeUnit = TimeUnit.MINUTES)
     public void sendLandingWideBodyFlights() throws InterruptedException {
         log.info("Schedule sending landing flights started...");
 
+        long startTime = System.currentTimeMillis();
+
         List<FlightEntity> uniqueRegistrations = flightService.findUniqueFlightsRegistrations();
         List<FlightDataDto> flightDataDtos = new ArrayList<>();
 
@@ -251,12 +259,18 @@ public void sendLandingWideBodyFlights() throws InterruptedException {
                 }
             }
         }
-        log.info("Schedule sending landing flights finished.");
+
+        long endTime = System.currentTimeMillis();
+
+        log.info("Schedule sending landing flights finished. {}", loggingUtils.getFinishedProcessTime(startTime, endTime));
     }
 
     @Scheduled(fixedDelay = AN_124_FLIGHTS_CHECK_DELAY_IN_MINUTES, timeUnit = TimeUnit.MINUTES)
     public void sendNewAn124Flights() {
         log.info("Schedule sending An-124 flights started...");
+
+        long startTime = System.currentTimeMillis();
+
         List<UserEntity> users = userService.findAllUsers();
 
         An124FlightsDto an124FlightsDto;
@@ -588,6 +602,9 @@ public void sendNewAn124Flights() {
                 }
             }
         }
-        log.info("Schedule sending An-124 flights finished.");
+
+        long endTime = System.currentTimeMillis();
+
+        log.info("Schedule sending An-124 flights finished. {}", loggingUtils.getFinishedProcessTime(startTime, endTime));
     }
 }

telegram-bot/src/main/java/project/vilsoncake/telegrambot/utils/LoggingUtils.java

@@ -0,0 +1,20 @@
+package project.vilsoncake.telegrambot.utils;
+
+import org.springframework.stereotype.Component;
+
+@Component
+public class LoggingUtils {
+
+    public String getFinishedProcessTime(long startTime, long endTime) {
+        double timeInSeconds = (double) (endTime - startTime) / 1000;
+
+        if (timeInSeconds < 60) {
+            return String.format("Process time: %s seconds.", timeInSeconds);
+        }
+
+        int timeInMinutes = (int) (timeInSeconds / 60);
+        int remainder = (int) (timeInSeconds % 60);
+
+        return String.format("Process time: %s minutes %s seconds.", timeInMinutes, remainder);
+    }
+}