1.修复上传视频超时问题

zuoxiao

2025-01-08 7040f16f0c725cf72df65b70291f999ace6263ac

 app/src/main/java/com/dayu/pipirrapp/net/ApiManager.java

@@ -1,5 +1,8 @@
package com.dayu.pipirrapp.net;

import static com.dayu.pipirrapp.bean.net.UplodFileState.STATE_DONE;
import static com.dayu.pipirrapp.bean.net.UplodFileState.STATE_ERROR;
import static com.dayu.pipirrapp.bean.net.UplodFileState.STATE_UPDING;
import static com.luck.picture.lib.thread.PictureThreadUtils.runOnUiThread;

import android.annotation.SuppressLint;
@@ -290,15 +293,17 @@
//    }

    /**
     * 上传文件
     * 上传图片文件
     *
     * @param context
     * @param uplodData
     * @param listener
     */
    public void uploadFile(final Context context, final UplodFileState uplodData, final UploadFileListener listener, final AddPictureAdapter adapter) {
        MyLog.d("progressRequestBody>>>" + "path:" + uplodData.getFilePath());

        if (!TextUtils.isEmpty(uplodData.getFilePath())) {
            MyLog.d("progressRequestBody>>>" + "path:" + uplodData.getFilePath()+">>>uploadType:"+uplodData.getUploadType());
            uplodData.setState(STATE_UPDING);
            File file = new File(uplodData.getFilePath());
            RequestBody requestBody = RequestBody.create(MediaType.parse("multipart/form-data"), file);
            ProgressRequestBody progressRequestBody = new ProgressRequestBody(requestBody, (bytesWritten, contentLength, done) -> {
@@ -318,23 +323,38 @@
            });
            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);
            Call<BaseResponse> uploadFile = null;
            switch (uplodData.getUploadType()) {
                case UplodFileState.IMG_TYPE:
                    uploadFile = apiService.uploadImgFile(body, description);
                    break;
                case UplodFileState.VIDEO_TYPE:
                    uploadFile = apiService.uploadVideoFile(body, description);
                    break;
                default:
                    uploadFile = apiService.uploadImgFile(body, description);
                    break;
            }

            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.setState(STATE_DONE);
                            uplodData.setPostId(((LinkedTreeMap) response.body().getContent()).get("id").toString());
                            uplodData.setWebPath(((LinkedTreeMap) response.body().getContent()).get("webPath").toString());
                            listener.onBack(uplodData);
                        } else {
                            MyLog.d("progressRequestBody>>>" + response.body().getMsg());
                            if (uplodData.getNumber() <= uplodFilerepeatSize) {
                                uplodData.setNumber(uplodData.getNumber() + 1);
                                uplodData.setState(2);
                                uplodData.setState(STATE_ERROR);
                                uploadFile(context, uplodData, listener, adapter);
                            } else {
                                uplodData.setState(STATE_ERROR);
                                uplodData.setNumber(0);
                                listener.onBack(uplodData);
                            }
                        }
@@ -343,22 +363,24 @@

                @Override
                public void onFailure(Call<BaseResponse> call, Throwable t) {
                    MyLog.d("progressRequestBody>>>" + "onFailure:");
                    if (uplodData.getNumber() <= uplodFilerepeatSize) {
                        uplodData.setNumber(uplodData.getNumber() + 1);
                        uplodData.setState(2);
                        uploadFile(context, uplodData, listener, adapter);
                    } else {
                        listener.onBack(uplodData);
                    MyLog.d("progressRequestBody>>>" + "onFailure:" + t.getMessage());
                    if (!t.getMessage().equals("Canceled")) {
                        uplodData.setState(STATE_ERROR);
                        if (uplodData.getNumber() <= uplodFilerepeatSize) {
                            uplodData.setNumber(uplodData.getNumber() + 1);
                            uploadFile(context, uplodData, listener, adapter);
                        } else {
                            uplodData.setNumber(0);
                            listener.onBack(uplodData);
                        }
                    }

                }
            });
        } else {
            uplodData.setState(UplodFileState.STATE_ERROR);
            uplodData.setState(STATE_ERROR);
            listener.onBack(uplodData);
        }


    }