问工作经理的定期工作请求在给定实例中对同一工作执行多个请求

EN

public class CloseFlight extends Worker {

    private FlightRepository flightRepo;
    public Context context;
    DateTimeFormatter formatter;
    LocalDateTime final_departure_time;

    String aircraft_type;



    public CloseFlight(@NonNull Context context, @NonNull WorkerParameters workerParams) {
        super(context, workerParams);
        this.flightRepo = new FlightRepository(context);
    }

    @RequiresApi(api = Build.VERSION_CODES.O)
    @NonNull
    @Override
    public Result doWork() {
        String flightnumber = getInputData().getString("flightno");
        String date = getInputData().getString("departuredate");

        formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm");

        if(!(flightnumber==null || date == null)) {
            Flight flight_value = flightRepo.getFlight(flightnumber,date);

            String departure_time = flight_value.getFinal_departure_time();
            final_departure_time = LocalDateTime.parse(departure_time, formatter);

            String datetime_now = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm"));
            LocalDateTime time_now = LocalDateTime.parse(datetime_now, formatter);


            long diffInMinutes = Duration.between(final_departure_time, time_now).toMinutes();
            String email_status = flight_value.getFlight_closure_status();


            \\I want this to be executed just once 
            if(diffInMinutes>60 && email_status.contentEquals("opened")) {

                aircraft_type = flight_value.getAircraft_type();

                String email = "Details " + "\n" + flightnumber + " " + date + "\n" + "\n" + "Date: " + " " + date + "\n" + "Aircraft Type: " + " " + aircraft_type;

                //Sending the email from here
                JavaMailAPI javaMailAPI = new JavaMailAPI(context, "myemailid@gmail.com", "Email for " + flightnumber + " and Departure date: " + date, email);
                javaMailAPI.execute();

                FlightClosureStatus flightClosureStatus = new FlightClosureStatus(flightnumber, date, "emailsent");
                flightRepo.updateFlightClosureStatus(flightClosureStatus);

            }

        }

        return Result.success();
    }


}

for(int i =0 ; i< length_report; i ++) {
    String status = reportitems.get(i).getStatus();


    if(status.contentEquals("opened")){
        String flightNumber = reportitems.get(i).getFlightNumber();
        String departureDate = reportitems.get(i).getDepartureDate();


        Data data = new Data.Builder()
            .putString("flightno", flightNumber)
            .putString("departuredate", departureDate).build();

        Constraints constraints = new Constraints.Builder()
            .setRequiredNetworkType(NetworkType.CONNECTED)
            .build();

        final PeriodicWorkRequest periodicWorkRequest2 = new PeriodicWorkRequest.Builder(CloseFlight.class,15, TimeUnit.MINUTES)
            .setConstraints(constraints)
            .setInputData(data)
            .build();

        WorkManager workManager =  WorkManager.getInstance(ReportListingActivity.this);

        workManager.enqueue(periodicWorkRequest2);

        workManager.getWorkInfoByIdLiveData(periodicWorkRequest2.getId())
            .observe(ReportListingActivity.this, new Observer<WorkInfo>() {
                @Override
                public void onChanged(@Nullable WorkInfo workInfo) {
                    if (workInfo != null) {
                        Log.d("periodicWorkRequest", "Status changed to : " + workInfo.getState());
                    }
                }
        });
    }
}