From fafdeae594f79bad8133837e5cde239afca4da54 Mon Sep 17 00:00:00 2001
From: zuoxiao <470321431@qq.com>
Date: 星期五, 06 十二月 2024 16:13:02 +0800
Subject: [PATCH] 1.优化工单列表状态显示 2.接口添加token失效判断,失效后跳转到登录界面。

---
 app/src/main/java/com/dayu/pipirrapp/net/ApiManager.java |  103 +++++++++++++++++++++++++++++++++++++++------------
 1 files changed, 79 insertions(+), 24 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..fad2f78 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,13 @@
 package com.dayu.pipirrapp.net;
 
+import static com.luck.picture.lib.thread.PictureThreadUtils.runOnUiThread;
+
 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 +15,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;
@@ -124,6 +135,12 @@
                     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());
@@ -261,34 +278,44 @@
      * 涓婁紶鏂囦欢
      *
      * @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");
+        apiService.uploadFile(body, description).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 +323,44 @@
 
             @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);
                 }
             }
         });
     }
 
+    /**
+     * 鍒ゆ柇褰撳墠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