From 32275aa66faa5371467e291b7d19a5e782f8aade Mon Sep 17 00:00:00 2001
From: zuoxiao <470321431@qq.com>
Date: 星期三, 18 十二月 2024 16:47:18 +0800
Subject: [PATCH] 1.修改取水口坐标相关代码
---
app/src/main/java/com/dayu/pipirrapp/net/ApiManager.java | 286 ++++++++++++++++++++++++++++++++++++++++++++++++++-------
1 files changed, 251 insertions(+), 35 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 e1e46c2..d6ba8f9 100644
--- a/app/src/main/java/com/dayu/pipirrapp/net/ApiManager.java
+++ b/app/src/main/java/com/dayu/pipirrapp/net/ApiManager.java
@@ -1,27 +1,40 @@
package com.dayu.pipirrapp.net;
+import static com.luck.picture.lib.thread.PictureThreadUtils.runOnUiThread;
+
+import android.annotation.SuppressLint;
import android.content.Context;
+import android.content.Intent;
+import android.util.Log;
-
+import com.dayu.pipirrapp.MyApplication;
+import com.dayu.pipirrapp.activity.LoginActivity;
+import com.dayu.pipirrapp.bean.net.CodeResult;
+import com.dayu.pipirrapp.bean.net.UplodFileState;
+import com.dayu.pipirrapp.bean.net.WeatherResponse;
import com.dayu.pipirrapp.net.subscribers.BaseProgressSubscriber;
+import com.dayu.pipirrapp.net.subscribers.CodeListener;
import com.dayu.pipirrapp.net.subscribers.ProgressSubscriber;
import com.dayu.pipirrapp.net.subscribers.SubscriberListener;
+import com.dayu.pipirrapp.net.upload.ProgressListener;
+import com.dayu.pipirrapp.net.upload.ProgressRequestBody;
+import com.dayu.pipirrapp.net.upload.UploadFileListener;
+import com.dayu.pipirrapp.utils.CleanDataUtils;
+import com.dayu.pipirrapp.utils.MapJpgUtils;
import com.dayu.pipirrapp.utils.MyJsonParser;
+import com.dayu.pipirrapp.utils.MyLog;
+import com.dayu.pipirrapp.utils.NetUtils;
+import com.google.gson.Gson;
+import com.google.gson.internal.LinkedTreeMap;
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;
@@ -41,12 +54,18 @@
*/
public class ApiManager {
+ static String TAG = "ApiManager";
+
static ApiManager apiManager;
//鏂囦欢涓婁紶澶辫触閲嶅娆℃暟
int uplodFilerepeatSize = 3;
ApiService apiService;
+ private CompositeDisposable compositeDisposable = new CompositeDisposable(); // 绠＄悊璁㈤槄浜嬩欢
+ /**
+ * 鍒濆鍖栭�氫俊妗嗘灦
+ */
public static void init() {
if (apiManager == null) {
apiManager = new ApiManager();
@@ -55,6 +74,7 @@
public ApiManager() {
apiService = RetrofitClient.getInstance().getApiService();
+
}
public static ApiManager getInstance() {
@@ -72,6 +92,14 @@
public <T> void requestPost(final Context context, final String path, final Class<T> tClass, final Map<String, Object> params, final SubscriberListener listener) {
request(context, false, path, false, tClass, params, listener);
+ }
+
+ public <T> void requestGet(final Context context, final String path, final Class<T> tClass, final Map<String, Object> params, final SubscriberListener listener) {
+ request(context, false, path, true, tClass, params, listener);
+ }
+
+ public <T> void requestGetHideLoading(final Context context, final String path, final Class<T> tClass, final Map<String, Object> params, final SubscriberListener listener) {
+ request(context, true, path, true, tClass, params, listener);
}
/**
@@ -93,10 +121,9 @@
if (isGet) {
if (params == null) {
- observable = apiService.requestGet(path);
+ observable = apiService.requestGet(path, MyApplication.myApplication.token);
} else {
-
- observable = apiService.requestGet(path, params);
+ observable = apiService.requestGet(path, params, MyApplication.myApplication.token);
}
} else {
observable = apiService.requestPost(path, params);
@@ -109,37 +136,26 @@
public BaseResponse<T> apply(Object o) {
if (o instanceof BaseResponse) {
BaseResponse tem = (BaseResponse) o;
+ if (tem.getCode().equals("0000")) {
+ //褰揷ode涓�0000鏄烦杞埌鐧诲綍鐣岄潰
+ tem.setMsg("鐧诲綍澶辨晥璇烽噸鏂扮櫥褰�");
+ redirectToLogin();
+ return tem;
+ }
BaseResponse<T> response = new BaseResponse<>();
response.setCode(tem.getCode());
response.setMsg(tem.getMsg());
- if (tClass != null && tem.getContent() instanceof Map) {
- try {
-// response.setData(MyJsonParser.getBeanFromMap((Map<String, Object>) tem.getData(), tClass));
- String jsonData = MyJsonParser.getJsontoMap((Map) tem.getContent());
- response.setContent(MyJsonParser.getBeanFromJson(jsonData, tClass));
- } catch (Exception e) {
- e.printStackTrace();
- }
- } else if (tClass != null && tem.getContent() instanceof List) {
- try {
- response.setContent((T) MyJsonParser.getListByJson(MyJsonParser.getJsonbyList((List) tem.getContent()), tClass));
- } catch (Exception e) {
- e.printStackTrace();
- }
- } else if (tClass != null && tem.getContent() instanceof Integer) {
- response.setContent((T) tem.getContent());
- }
- if (tClass != null && tClass.getName() instanceof String && tem.getContent() instanceof String) {
- try {
+ if (tClass != null) {
+ if (tem.getContent() instanceof Map) {
+ response.setContent(parseMapContent(tem.getContent(), tClass));
+ } else if (tem.getContent() instanceof List) {
+ response.setContent(parseListContent(tem.getContent(), tClass));
+ } else if (tem.getContent() instanceof Integer || tem.getContent() instanceof String) {
response.setContent((T) tem.getContent());
- } catch (Exception e) {
- e.printStackTrace();
}
}
return response;
-
-
}
return null;
@@ -152,4 +168,204 @@
}
+ // 瑙ｆ瀽 Map 绫诲瀷鐨勬暟鎹�
+ private <T> T parseMapContent(Object content, Class<T> tClass) {
+ try {
+ String jsonData = MyJsonParser.getJsontoMap((Map<String, Object>) content);
+ return MyJsonParser.getBeanFromJson(jsonData, tClass);
+ } catch (Exception e) {
+ Log.e(TAG, "Error parsing map content", e);
+ return null;
+ }
+ }
+
+ // 瑙ｆ瀽 List 绫诲瀷鐨勬暟鎹�
+ private <T> T parseListContent(Object content, Class<T> tClass) {
+ try {
+ String jsonData = MyJsonParser.getJsonbyList((List<?>) content);
+ return (T) MyJsonParser.getListByJson(jsonData, tClass);
+ } catch (Exception e) {
+ Log.e(TAG, "Error parsing list content", e);
+ return null;
+ }
+ }
+
+ /**
+ * 鑾峰彇澶╂皵
+ *
+ * @param data 缁忕含搴︼紙鏍煎紡鏄� 绾害:缁忓害锛岃嫳鏂囧啋鍙峰垎闅旓級
+ * @param callback
+ * @param <T>
+ */
+ public <T> void requestWeather(String data, Callback<WeatherResponse> callback) {
+ Map<String, Object> params = new HashMap<>();
+ params.put("key", "S6Tq4pvOakMuWRrg0");
+ params.put("location", data);
+ params.put("language", "zh-Hans");
+ params.put("unit", "c");
+ params.put("days", "3");
+ Call<WeatherResponse> call = apiService.requestWeather("https://api.seniverse.com/v3/weather/daily.json", params);
+ call.enqueue(callback);
+ }
+
+
+ /**
+ * 鑾峰彇楠岃瘉鐮�
+ *
+ * @param params
+ * @param listener
+ * @param <T>
+ */
+ public <T> void getCode(Map<String, Object> params, CodeListener listener) {
+ if (NetUtils.isNetworkAvailable(MyApplication.myApplication)) {
+ Observable observable;
+ observable = apiService.getCode(params);
+ observable.subscribeOn(Schedulers.io())
+ .unsubscribeOn(Schedulers.newThread())
+ .observeOn(AndroidSchedulers.mainThread())
+ .subscribe(responseBody -> {
+ listener.onNext((CodeResult) responseBody);
+ }, throwable -> {
+ listener.error((Throwable) throwable);
+ });
+ } else {
+ listener.onNext(null);
+ }
+
+ }
+
+
+ /**
+ * 涓嬭浇鍦板浘鐡︾墖
+ *
+ * @param urlPath
+ */
+ @SuppressLint("CheckResult")
+ public void donwLoadTile(Context context, String urlPath) {
+ if (NetUtils.isNetworkAvailable(context)) {
+ Observable<ResponseBody> observable;
+ observable = apiService.downloadTile(urlPath);
+ observable
+ .subscribeOn(Schedulers.io()) // 缃戠粶璇锋眰鍦� I/O 绾跨▼涓繘琛�
+ .observeOn(Schedulers.io()) // 鍥炶皟澶勭悊涔熷湪 I/O 绾跨▼
+ .subscribe(
+ responseBody -> {
+
+ boolean success = false;
+ if (!MapJpgUtils.getInsatance().isHasFiles(urlPath)) {
+ success = MapJpgUtils.getInsatance().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)
+ );
+ } else {
+ Log.e(TAG, "娌℃湁缃戠粶涓嶄笅杞�: " + urlPath);
+ }
+ }
+
+ // 鍋滄绾跨▼姹狅紝閲婃斁璧勬簮
+ public void clearDisposables() {
+ if (!compositeDisposable.isDisposed()) {
+ compositeDisposable.dispose();
+ }
+ }
+
+
+ /**
+ * 涓婁紶鏂囦欢
+ *
+ * @param context
+ * @param uplodData
+ * @param listener
+ */
+ public void uploadFile(final Context context, final UplodFileState uplodData, final UploadFileListener listener) {
+
+ File file = new File(uplodData.getFilePath());
+ RequestBody requestBody = RequestBody.create(MediaType.parse("multipart/form-data"), file);
+ ProgressRequestBody progressRequestBody = new ProgressRequestBody(requestBody, new ProgressListener() {
+ @Override
+ public void onProgress(long bytesWritten, long contentLength, boolean done) {
+ // 鏇存柊杩涘害鏉℃垨杩涜鍏朵粬鎿嶄綔
+ int progress = (int) (100 * bytesWritten / contentLength);
+ // 渚嬪锛氭洿鏂� ProgressBar 鎴栨樉绀鸿繘搴�
+ runOnUiThread(() -> {
+ // 杩涘害鏉℃洿鏂颁唬鐮�
+ // progressBar.setProgress(progress);
+ MyLog.d("progressRequestBody>>>" + "涓婁紶杩涘害: " + progress + "%");
+ });
+ }
+ });
+ MultipartBody.Part body = MultipartBody.Part.createFormData("file", file.getName(), progressRequestBody);
+ RequestBody description = RequestBody.create(MediaType.parse("text/plain"), "file description");
+ Call<BaseResponse> uploadFile = apiService.uploadFile(body, description);
+ uplodData.setThisCall(uploadFile);
+ uploadFile.enqueue(new Callback<BaseResponse>() {
+ @Override
+ public void onResponse(Call<BaseResponse> call, Response<BaseResponse> response) {
+ if (response.body() != null) {
+ if (response.body().isSuccess()) {
+ uplodData.setState(1);
+ uplodData.setId(((LinkedTreeMap) response.body().getContent()).get("id").toString());
+ uplodData.setWebPath(((LinkedTreeMap) response.body().getContent()).get("webPath").toString());
+ listener.onBack(uplodData);
+ } else {
+ if (uplodData.getNumber() <= uplodFilerepeatSize) {
+ uplodData.setNumber(uplodData.getNumber() + 1);
+ uplodData.setState(2);
+ uploadFile(context, uplodData, listener);
+ } else {
+ listener.onBack(uplodData);
+ }
+ }
+ }
+ }
+
+ @Override
+ public void onFailure(Call<BaseResponse> call, Throwable t) {
+ if (uplodData.getNumber() <= uplodFilerepeatSize) {
+ uplodData.setNumber(uplodData.getNumber() + 1);
+ uplodData.setState(2);
+ uploadFile(context, uplodData, listener);
+ } else {
+ listener.onBack(uplodData);
+ }
+ }
+ });
+
+ }
+
+ /**
+ * 鍒ゆ柇褰撳墠code鏄惁鏄湭鐧诲綍鐘舵��
+ *
+ * @param responseBody the response body in JSON format
+ * @return true if login is required, false otherwise
+ */
+ private boolean isLoginRequired(String responseBody) {
+ try {
+ Gson gson = new Gson();
+ Map<String, Object> responseMap = gson.fromJson(responseBody, Map.class);
+ String code = (String) responseMap.get("code");
+ return "0000".equals(code); // Check if the code is not 0000
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return false;
+ }
+
+ /**
+ * 褰揷ode涓衡��0000鈥濇椂璺宠浆鍒扮櫥褰曠晫闈�
+ */
+ private void redirectToLogin() {
+
+ Context context = MyApplication.myApplication.getApplicationContext();
+ CleanDataUtils.cleanUserData(context);
+ Intent intent = new Intent(context, LoginActivity.class); // Assuming LoginActivity is your login screen
+ intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK | Intent.FLAG_ACTIVITY_CLEAR_TASK); // Clear task stack
+ context.startActivity(intent);
+ }
}
\ No newline at end of file
--
Gitblit v1.8.0