我遇到了同样的问题,这个解决方案对我有用:
如下定义一个工人:
class SendLocationWorker(
context: Context,
workerParams: WorkerParameters
) : Worker(context, workerParams) {
private var retrofit: Retrofit? = null
private var locationApi: MyApi? = null
private val userLocationDao = AppDatabase.getInstance(applicationContext)
.userLocationDao()
override fun doWork(): Result {
return try {
if (retrofit == null) {
retrofit = MasterRetrofit().initRetrofit(Constants.MAIN_URL)
}
if (locationApi == null) {
locationApi = retrofit!!.create(MyApi::class.java)
}
callApi()
Result.success()
} catch (ex: Exception) {
Result.failure()
}
}
@SuppressLint("CheckResult")
private fun callApi() {
val locations = getUserLocations()
if (locations.isNotEmpty()) {
val request = InsertLocationUserRequest()
request.saveTrackings = locations
locationApi!!.SaveTracking(request)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.map(SuccessMapper<Response<InsertLocationUserResponse>>())
.subscribe(
{ response ->
if (response.body()!!.success) {
Observable.fromIterable(locations)
.forEach { location -> location.isSync = true }
userLocationDao.update(locations)
}
},
{ throwable ->
},
{
}
)
}
}
private fun getUserLocations(): List<UserLocation> {
return userLocationDao.findAll("isSync", "0")
}
}
另外,您需要像这样在 MasterActivity 或 MasterPresenter 中定义一个方法:
@Override public void sendStoredLocationToServer() {
Constraints myConstraints = new Constraints.Builder()
.setRequiresBatteryNotLow(true)
.build();
PeriodicWorkRequest sendLocationWorkerRequest =
new PeriodicWorkRequest.Builder(SendLocationWorker.class, 10000, TimeUnit.MILLISECONDS)
.setConstraints(myConstraints)
.build();
WorkManager.getInstance().enqueueUniquePeriodicWork("sendLocationWorker",
ExistingPeriodicWorkPolicy.REPLACE,
sendLocationWorkerRequest);
}
然后,您可以在 MasterActivity 或 MasterPresenter 中调用您的工作人员,如下所示:
sendStoredLocationToServer();
此工作人员会将您的位置保存在数据库中并在可能的情况下发送它们,并将所有发送项目标记为 true(使用 isSyns 标志)。
这个想法对我很有效。