Блог

Я хочу периодически синхронизировать базу данных Room. Для этого я использую work Manager. Я создал периодический запрос на работу и хочу отправить таблицу с setInputData(TABLE HERE..) . Я хочу знать, правильно ли я это делаю. И если правильно, как я могу периодически отправлять таблицу в work Manager? Если это не так, пожалуйста, помогите мне с подходящим решением.

Вот мой код:

 //schedule recurring task only once
//Fragment
    if(!SessionManager.getBoolenFromPreferences(getActivity(),REFRESH_ATTENDANCE)){
        attendanceViewModel.setupPeriodicRefreshWork();
        SessionManager.putBoolenInPreferences(getActivity(), true, REFRESH_ATTENDANCE);
    }

//view model
public void setupPeriodicRefreshWork() {
    AttendanceScheduler.refreshWork();
}

//Scheduler
public static void refreshWork() {

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

  //How to Set Data Here ?
    Data source = new Data.Builder()
            .put(HERE)
            .build();

    PeriodicWorkRequest refreshWork =
            new PeriodicWorkRequest.Builder(AttendanceWorker.class, 1, TimeUnit.HOURS)
                    .setConstraints(myConstraints)
                    .setInputData(source)
                    .build();

    WorkManager.getInstance().enqueue(refreshWork);
}
  

Вот мой рабочий код:

 public class AttendanceWorker extends Worker {

    private Executor executor;
    private static final String TAG = "AttendanceWorker";

    public AttendanceWorker(@NonNull Context context, @NonNull WorkerParameters workerParams) {
        super(context, workerParams);
        executor = Executors.newSingleThreadExecutor();
    }


    @SuppressLint("CheckResult")
    @NonNull
    @Override
    public Result doWork() {
        Context context = getApplicationContext();
        AttendanceDao attendanceDao = DatabaseInstance.getInstance(context).attendanceDao();
        Attendance attendance = attendanceDao.getAttendanceDetailsForSync();
        NetworkUtils.getAPIService().saveAttendanceDetails(attendance).compose(RxUtils.applySchedulers())
                .subscribe(
                        (AttendanceResponse attendanceResponse) -> executor.execute(() ->
                        {
                            if (attendanceResponse != null) {
                                if (attendanceResponse.getResult().equals("1")) {
                                    Log.d(TAG, "Attendance Synced!");
                                }
                            }
                        }),
                        Throwable::printStackTrace
                );
        return Result.success();
    }

}