From 21e38bfe17d3077d7ab0e05ee065f59547536692 Mon Sep 17 00:00:00 2001
From: zuoxiao <470321431@qq.com>
Date: 星期二, 03 十二月 2024 10:33:19 +0800
Subject: [PATCH] 1.添加当前巡检状态的功能。 2.修复工单界面刷新已完成列表导致未完成列表数据被清除的bug
---
app/src/main/java/com/dayu/pipirrapp/net/ApiManager.java | 62 +++++++++++++++++++++++++++++++
1 files changed, 62 insertions(+), 0 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 3ff5033..8e03e6f 100644
--- a/app/src/main/java/com/dayu/pipirrapp/net/ApiManager.java
+++ b/app/src/main/java/com/dayu/pipirrapp/net/ApiManager.java
@@ -9,11 +9,13 @@
import com.dayu.pipirrapp.MyApplication;
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.UploadFileListener;
import com.dayu.pipirrapp.utils.MapJpgUtils;
import com.dayu.pipirrapp.utils.MyJsonParser;
@@ -26,9 +28,13 @@
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;
/**
@@ -81,6 +87,9 @@
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);
}
/**
@@ -282,4 +291,57 @@
return false; // 鏃犵綉缁滆繛鎺�
}
+ /**
+ * 涓婁紶鏂囦欢
+ *
+ * @param context
+ * @param file
+ * @param listener
+ */
+ public void uploadFile(final Context context, final UplodFileState file, 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>() {
+ @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);
+ } else {
+ if (file.getNumber() <= uplodFilerepeatSize) {
+ file.setNumber(file.getNumber() + 1);
+ file.setState(2);
+ uploadFile(context, file, listener);
+ } else {
+ listener.onBack(file);
+ }
+ }
+ }
+ }
+
+ @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);
+ } else {
+ listener.onBack(file);
+ }
+ }
+ });
+ }
+
+
+
+
}
\ No newline at end of file
--
Gitblit v1.8.0