From 7040f16f0c725cf72df65b70291f999ace6263ac Mon Sep 17 00:00:00 2001
From: zuoxiao <470321431@qq.com>
Date: 星期三, 08 一月 2025 11:00:36 +0800
Subject: [PATCH] 1.修复上传视频超时问题

---
 app/src/main/java/com/dayu/pipirrapp/activity/OrderDealActivity.java |  129 ++++++++++++++++++++++++++----------------
 1 files changed, 79 insertions(+), 50 deletions(-)

diff --git a/app/src/main/java/com/dayu/pipirrapp/activity/OrderDealActivity.java b/app/src/main/java/com/dayu/pipirrapp/activity/OrderDealActivity.java
index a50d481..fef6b3d 100644
--- a/app/src/main/java/com/dayu/pipirrapp/activity/OrderDealActivity.java
+++ b/app/src/main/java/com/dayu/pipirrapp/activity/OrderDealActivity.java
@@ -4,7 +4,6 @@
 
 import android.content.Context;
 import android.content.Intent;
-import android.os.Build;
 import android.os.Bundle;
 import android.text.TextUtils;
 import android.util.Log;
@@ -30,11 +29,13 @@
 import com.dayu.pipirrapp.net.BaseResponse;
 import com.dayu.pipirrapp.net.subscribers.SubscriberListener;
 import com.dayu.pipirrapp.net.upload.UploadFileListener;
-import com.dayu.pipirrapp.service.MyLocationService;
+import com.dayu.pipirrapp.tool.FileUploadUtils;
 import com.dayu.pipirrapp.tool.FullyGridLayoutManager;
 import com.dayu.pipirrapp.tool.GlideEngine;
 import com.dayu.pipirrapp.tool.ImageFileCompressEngine;
 import com.dayu.pipirrapp.utils.CommonKeyName;
+import com.dayu.pipirrapp.utils.MyLog;
+import com.dayu.pipirrapp.utils.ServiceUtils;
 import com.dayu.pipirrapp.utils.ToastUtil;
 import com.dayu.pipirrapp.view.TitleBar;
 import com.jeremyliao.liveeventbus.LiveEventBus;
@@ -53,8 +54,10 @@
 import com.tencent.bugly.crashreport.CrashReport;
 
 import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
+import java.util.Map;
 import java.util.Set;
 
 import retrofit2.Call;
@@ -68,7 +71,7 @@
  * @since 2024-11-27
  */
 public class OrderDealActivity extends BaseActivity {
-    private String TAG = "OrderDealActivity";
+    private final String TAG = "OrderDealActivity";
     ActivityOrderDealBinding binding;
     RecyclerView mRecyclerView;
     AddPictureAdapter mAdapter;
@@ -77,7 +80,8 @@
     private final List<LocalMedia> mData = new ArrayList<>();
     private ActivityResultLauncher<Intent> launcherResult;
     private ImageEngine imageEngine;
-    List<UplodFileState> uplodFileStates = new ArrayList<>();
+    //    List<UplodFileState> uplodFileStates = new ArrayList<>();
+    Map<String, UplodFileState> uplodFileStates = new HashMap<>();
     String workOrderId;
     LatLonBean latLonBean;
 
@@ -87,6 +91,7 @@
     private Observer<Object> locationObserver = new Observer<Object>() {
         @Override
         public void onChanged(Object o) {
+            MyLog.d("OrderDealActivity>>>locationObserver>>");
             latLonBean = (LatLonBean) o;
         }
     };
@@ -115,7 +120,7 @@
         }
         mRecyclerView.addItemDecoration(new GridSpacingItemDecoration(4,
                 DensityUtil.dip2px(this, 8), false));
-        mAdapter = new AddPictureAdapter(this, mData);
+        mAdapter = new AddPictureAdapter(this, mData, uplodFileStates);
         mAdapter.setSelectMax(maxSelectNum + maxSelectVideoNum);
         mRecyclerView.setAdapter(mAdapter);
         imageEngine = GlideEngine.createGlideEngine();
@@ -140,10 +145,16 @@
             public void onDeleteClick(int position) {
                 deleteItem(position);
             }
+
+            @Override
+            public void onReUpload(UplodFileState uplodFileState) {
+                uplodFileState.setState(UplodFileState.STATE_UPDING);
+                uplodeImg(uplodFileState);
+            }
         });
         binding.dealButton.setOnClickListener(v -> {
             boolean isAllPost = true;
-            for (UplodFileState imgData : uplodFileStates) {
+            for (UplodFileState imgData : uplodFileStates.values()) {
                 if (imgData.getState() == 0) {
                     isAllPost = false;
                 }
@@ -224,10 +235,13 @@
      * @param result
      */
     private void analyticalSelectResults(ArrayList<LocalMedia> result) {
+        //鑾峰彇褰撳墠uplodFileStates鎵�鏈夌殑鍥剧墖鍦板潃
         Set<String> existingPaths = new HashSet<>();
-        for (UplodFileState uplodData : uplodFileStates) {
+        for (UplodFileState uplodData : uplodFileStates.values()) {
             existingPaths.add(uplodData.getFilePath());
         }
+        //鑾峰彇鍦≒ictureSelector鐨勭浉鍐屾椂鍙栨秷閫変腑鐨勫浘鐗�
+        Set<String> resultPaths = new HashSet<>();
         for (LocalMedia media : result) {
             if (media.getWidth() == 0 || media.getHeight() == 0) {
                 if (PictureMimeType.isHasImage(media.getMimeType())) {
@@ -258,48 +272,57 @@
             Log.i(TAG, "鏂囦欢鏃堕暱: " + media.getDuration());
             String compressPath = media.getCompressPath();
             //鍒ゆ柇鏄惁鏈夎繖涓矾寰勶紝娌℃湁鐨勮瘽涓婁紶璇ュ浘鐗�
+            if (TextUtils.isEmpty(compressPath)) {
+                compressPath = media.getRealPath();
+            }
             if (!existingPaths.contains(compressPath)) {
                 UplodFileState uplodFileState = new UplodFileState();
                 uplodFileState.setFilePath(compressPath);
-                uplodFileStates.add(uplodFileState);
+                if (compressPath.toLowerCase().endsWith(".mp4") || compressPath.toLowerCase().endsWith(".avi") || compressPath.toLowerCase().endsWith(".mkv") || compressPath.toLowerCase().endsWith(".mov")) {
+                    // 杩欐槸瑙嗛鏂囦欢
+                    uplodFileState.setUploadType(UplodFileState.VIDEO_TYPE);
+                }else {
+                    uplodFileState.setUploadType(UplodFileState.IMG_TYPE);
+                }
+                uplodFileStates.put(compressPath, uplodFileState);
                 // 鎵ц涓婁紶鍥剧墖鐨勬搷浣�
                 uplodeImg(uplodFileState);
             }
 
-
+            resultPaths.add(media.getCompressPath());
         }
-        runOnUiThread(new Runnable() {
-            @Override
-            public void run() {
-                boolean isMaxSize = result.size() == mAdapter.getSelectMax();
-                int oldSize = mAdapter.getData().size();
-                mAdapter.notifyItemRangeRemoved(0, isMaxSize ? oldSize + 1 : oldSize);
-                mAdapter.getData().clear();
-
-                mAdapter.getData().addAll(result);
-                mAdapter.notifyItemRangeInserted(0, result.size());
-
+        //澶勭悊浠庣浉鍐岃繑鍥炴椂鍙栨秷鐨勫浘鐗囧鐞�
+        existingPaths.removeAll(resultPaths);
+        if (!existingPaths.isEmpty()) {
+            List<UplodFileState> toRemove = new ArrayList<>();
+            for (String path : existingPaths) {
+                for (UplodFileState uplodFileState : uplodFileStates.values()) {
+                    if (path.equals(uplodFileState.getFilePath())) {
+                        uplodFileState.getThisCall().cancel();
+                        toRemove.add(uplodFileState);
+                    }
+                }
             }
+            for (UplodFileState removeFile : toRemove) {
+                uplodFileStates.remove(removeFile.getFilePath());
+            }
+        }
+        runOnUiThread(() -> {
+            boolean isMaxSize = result.size() == mAdapter.getSelectMax();
+            int oldSize = mAdapter.getData().size();
+            mAdapter.notifyItemRangeRemoved(0, isMaxSize ? oldSize + 1 : oldSize);
+            mAdapter.getData().clear();
+
+            mAdapter.getData().addAll(result);
+            mAdapter.notifyItemRangeInserted(0, result.size());
+
         });
     }
 
 
     //涓婁紶鍥剧墖
     private void uplodeImg(UplodFileState uplodFileState) {
-        ApiManager.getInstance().uploadFile(this, uplodFileState, new UploadFileListener() {
-            @Override
-            public void onBack(UplodFileState state) {
-                for (UplodFileState uplodFile : uplodFileStates) {
-                    if (uplodFile.getFilePath().equals(state.getFilePath())) {
-                        int index = uplodFileStates.indexOf(uplodFile);
-                        if (index != -1) {
-                            uplodFileStates.set(index, uplodFile); // 鏇存柊瀵瑰簲鐨勯」
-                        }
-                    }
-
-                }
-            }
-        });
+        FileUploadUtils.uploadFile(this, uplodFileState, uplodFileStates, mAdapter);
     }
 
     /**
@@ -340,14 +363,7 @@
      * 寮�濮嬪畾浣嶇浉鍏抽�昏緫
      */
     private void startLocation() {
-        Intent location = new Intent(this, MyLocationService.class);
-        location.putExtra("isSingle", true);
-        //寮�鍚畾浣�
-        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
-            startForegroundService(location);
-        } else {
-            startService(location);
-        }
+        ServiceUtils.startLocationService(this, true);
         //鑾峰彇瀹氫綅鏈嶅姟浼犺繃鏉ョ殑鍧愭爣鐐�
         LiveEventBus.get(CommonKeyName.locationData).observeForever(locationObserver);
     }
@@ -357,20 +373,33 @@
     protected void onDestroy() {
         super.onDestroy();
         LiveEventBus.get(CommonKeyName.locationData).removeObserver(locationObserver);
+        FileUploadUtils.cancelAllCall(uplodFileStates);
     }
 
     /**
      * 棰勮鍜屽浘鐗囧垪琛ㄥ垹闄ゅ浘鐗囨椂澶勭悊鍒犻櫎浜嬩欢
      */
     private void deleteItem(int position) {
-        try {
-            Call<BaseResponse> mCall = uplodFileStates.get(position).getThisCall();
-            if (mCall != null) {
-                mCall.cancel();
-            }
-        } catch (Exception e) {
-            e.printStackTrace();
+        LocalMedia localMedia = mAdapter.getData().get(position);
+        String path;
+        UplodFileState uplodFileState;
+        if (TextUtils.isEmpty(localMedia.getCompressPath())) {
+            uplodFileState = uplodFileStates.get(localMedia.getRealPath());
+        } else {
+            uplodFileState = uplodFileStates.get(localMedia.getCompressPath());
         }
-        uplodFileStates.remove(position);
+        if (uplodFileState != null) {
+            path = uplodFileState.getFilePath();
+            try {
+                Call<BaseResponse> mCall = uplodFileStates.get(path).getThisCall();
+                if (mCall != null) {
+                    mCall.cancel();
+                    MyLog.d("progressRequestBody>>>" + "cancel銆嬨�嬨�媝ath:" + path);
+                }
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+            uplodFileStates.remove(path);
+        }
     }
 }

--
Gitblit v1.8.0