From f163344ffeb1e699fa1a2dfb8a70055bb1b9be7e Mon Sep 17 00:00:00 2001
From: zuoxiao <470321431@qq.com>
Date: 星期一, 09 九月 2024 15:09:17 +0800
Subject: [PATCH] 首页界面优化，地图模块优化，部分下载地图瓦片功能代码
---
app/src/main/java/com/dayu/pipirrapp/net/ApiManager.java | 64 +++++++++++++++++++++++---------
1 files changed, 46 insertions(+), 18 deletions(-)
diff --git a/app/src/main/java/com/dayu/pipirrapp/net/ApiManager.java b/app/src/main/java/com/dayu/pipirrapp/net/ApiManager.java
index 186cf43..58a4dd0 100644
--- a/app/src/main/java/com/dayu/pipirrapp/net/ApiManager.java
+++ b/app/src/main/java/com/dayu/pipirrapp/net/ApiManager.java
@@ -1,38 +1,27 @@
package com.dayu.pipirrapp.net;
import android.content.Context;
-
+import android.util.Log;
import com.dayu.pipirrapp.bean.WeatherResponse;
import com.dayu.pipirrapp.net.subscribers.BaseProgressSubscriber;
import com.dayu.pipirrapp.net.subscribers.ProgressSubscriber;
import com.dayu.pipirrapp.net.subscribers.SubscriberListener;
+import com.dayu.pipirrapp.utils.MapJpgUtils;
import com.dayu.pipirrapp.utils.MyJsonParser;
-import java.io.File;
-import java.io.FileNotFoundException;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.io.InputStream;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
-import java.util.Objects;
import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers;
-import io.reactivex.rxjava3.annotations.NonNull;
import io.reactivex.rxjava3.core.Observable;
-import io.reactivex.rxjava3.core.Observer;
-import io.reactivex.rxjava3.disposables.Disposable;
+import io.reactivex.rxjava3.disposables.CompositeDisposable;
import io.reactivex.rxjava3.functions.Function;
import io.reactivex.rxjava3.schedulers.Schedulers;
-import okhttp3.MediaType;
-import okhttp3.MultipartBody;
-import okhttp3.RequestBody;
import okhttp3.ResponseBody;
import retrofit2.Call;
import retrofit2.Callback;
-import retrofit2.Response;
/**
@@ -43,11 +32,14 @@
*/
public class ApiManager {
+ static String TAG = "ApiManager";
+
static ApiManager apiManager;
//鏂囦欢涓婁紶澶辫触閲嶅娆℃暟
int uplodFilerepeatSize = 3;
ApiService apiService;
+ private CompositeDisposable compositeDisposable = new CompositeDisposable(); // 绠＄悊璁㈤槄浜嬩欢
/**
* 鍒濆鍖栭�氫俊妗嗘灦
@@ -60,6 +52,7 @@
public ApiManager() {
apiService = RetrofitClient.getInstance().getApiService();
+
}
public static ApiManager getInstance() {
@@ -157,14 +150,14 @@
}
-
/**
- * 鑾峰彇澶╂皵
- * @param data 缁忕含搴︼紙鏍煎紡鏄� 绾害:缁忓害锛岃嫳鏂囧啋鍙峰垎闅旓級
+ * 鑾峰彇澶╂皵
+ *
+ * @param data 缁忕含搴︼紙鏍煎紡鏄� 绾害:缁忓害锛岃嫳鏂囧啋鍙峰垎闅旓級
* @param callback
* @param <T>
*/
- public <T> void requestWeather(String data,Callback<WeatherResponse> callback) {
+ public <T> void requestWeather(String data, Callback<WeatherResponse> callback) {
Map<String, Object> params = new HashMap<>();
params.put("key", "S6Tq4pvOakMuWRrg0");
params.put("location", data);
@@ -176,4 +169,39 @@
}
+ public void donwLoadTile(Context context, String urlPath) {
+ Observable<ResponseBody> observable;
+ observable = apiService.downloadTile(urlPath);
+
+
+ compositeDisposable.add(
+ observable
+ .subscribeOn(Schedulers.io()) // 缃戠粶璇锋眰鍦� I/O 绾跨▼涓繘琛�
+ .observeOn(Schedulers.io()) // 鍥炶皟澶勭悊涔熷湪 I/O 绾跨▼
+ .subscribe(
+ responseBody -> {
+ boolean success = false;
+ if (!MapJpgUtils.getInsatance(context).isHasFiles(urlPath)) {
+ success = MapJpgUtils.getInsatance(context).saveTileToCache(urlPath, responseBody);
+ }
+ if (success) {
+ Log.d(TAG, "Download success for tile: " + urlPath);
+ } else {
+ Log.e(TAG, "Failed to save tile to disk: " + urlPath);
+ }
+ },
+ throwable -> Log.e(TAG, "Download failed for tile: " + urlPath)
+ )
+ );
+
+
+ }
+
+ // 鍋滄绾跨▼姹狅紝閲婃斁璧勬簮
+ public void clearDisposables() {
+ if (!compositeDisposable.isDisposed()) {
+ compositeDisposable.dispose();
+ }
+ }
+
}
\ No newline at end of file
--
Gitblit v1.8.0