From 6a44973461e2a91f62f7eed681b4db3abb026289 Mon Sep 17 00:00:00 2001
From: zuoxiao <470321431@qq.com>
Date: 星期二, 24 十二月 2024 16:52:23 +0800
Subject: [PATCH] 1.优化地图相关代码，提高运行效率和可读性。 2.添加修改密码功能。 3.优化列表和详情页展示。
---
app/src/main/java/com/dayu/pipirrapp/net/ApiManager.java | 102 +++++++++++++++++++++++++++++++++++++-------------
1 files changed, 75 insertions(+), 27 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 dc7a736..12f0033 100644
--- a/app/src/main/java/com/dayu/pipirrapp/net/ApiManager.java
+++ b/app/src/main/java/com/dayu/pipirrapp/net/ApiManager.java
@@ -1,9 +1,14 @@
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;
@@ -11,11 +16,18 @@
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.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -49,7 +61,8 @@
int uplodFilerepeatSize = 3;
ApiService apiService;
- private CompositeDisposable compositeDisposable = new CompositeDisposable(); // 绠＄悊璁㈤槄浜嬩欢
+ // 绠＄悊璁㈤槄浜嬩欢
+ private CompositeDisposable compositeDisposable = new CompositeDisposable();
/**
* 鍒濆鍖栭�氫俊妗嗘灦
@@ -124,6 +137,12 @@
public BaseResponse<T> apply(Object o) {
if (o instanceof BaseResponse) {
BaseResponse tem = (BaseResponse) o;
+ if (tem.getCode().equals(Constants.TOKEN_INVALID)) {
+ //褰揷ode涓�0000鏄烦杞埌鐧诲綍鐣岄潰
+ tem.setMsg("鐧诲綍澶辨晥璇烽噸鏂扮櫥褰�");
+ redirectToLogin();
+ return tem;
+ }
BaseResponse<T> response = new BaseResponse<>();
response.setCode(tem.getCode());
response.setMsg(tem.getMsg());
@@ -171,6 +190,7 @@
return null;
}
}
+
/**
* 鑾峰彇澶╂皵
@@ -222,13 +242,16 @@
*
* @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 绾跨▼
+ // 缃戠粶璇锋眰鍦� I/O 绾跨▼涓繘琛�
+ .subscribeOn(Schedulers.io())
+ // 鍥炶皟澶勭悊涔熷湪 I/O 绾跨▼
+ .observeOn(Schedulers.io())
.subscribe(
responseBody -> {
@@ -261,34 +284,46 @@
* 涓婁紶鏂囦欢
*
* @param context
- * @param file
+ * @param uplodData
* @param listener
*/
- public void uploadFile(final Context context, final UplodFileState file, final UploadFileListener listener) {
+ public void uploadFile(final Context context, final UplodFileState uplodData, final UploadFileListener listener) {
- // 鍒涘缓 RequestBody锛岀敤浜庡皝瑁呮瀯寤篟equestBody
- RequestBody requestFile =
- RequestBody.create(MediaType.parse("multipart/form-data"), file.getFile());
- // MultipartBody.Part 鍜屽悗绔害瀹氬ソKey锛岃繖閲岀殑partName鏄敤image
- MultipartBody.Part body = MultipartBody.Part.createFormData("file", file.getFile().getName(), requestFile);
- // 娣诲姞鎻忚堪
- String descriptionString = "hello, 杩欐槸鏂囦欢鎻忚堪";
- RequestBody description = RequestBody.create(MediaType.parse("multipart/form-data"), descriptionString);
- apiService.uploadFile(description, body).enqueue(new Callback<BaseResponse>() {
+ 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()) {
- file.setState(1);
- file.setUrl(response.body().getMsg());
- listener.onBack(file);
+ 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 (file.getNumber() <= uplodFilerepeatSize) {
- file.setNumber(file.getNumber() + 1);
- file.setState(2);
- uploadFile(context, file, listener);
+ if (uplodData.getNumber() <= uplodFilerepeatSize) {
+ uplodData.setNumber(uplodData.getNumber() + 1);
+ uplodData.setState(2);
+ uploadFile(context, uplodData, listener);
} else {
- listener.onBack(file);
+ listener.onBack(uplodData);
}
}
}
@@ -296,16 +331,29 @@
@Override
public void onFailure(Call<BaseResponse> call, Throwable t) {
- if (file.getNumber() <= uplodFilerepeatSize) {
- file.setNumber(file.getNumber() + 1);
- file.setState(2);
- uploadFile(context, file, listener);
+ if (uplodData.getNumber() <= uplodFilerepeatSize) {
+ uplodData.setNumber(uplodData.getNumber() + 1);
+ uplodData.setState(2);
+ uploadFile(context, uplodData, listener);
} else {
- listener.onBack(file);
+ listener.onBack(uplodData);
}
}
});
+
}
+
+ /**
+ * 褰揷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