处理最大视频过滤

吴奎庆
1 parent 8206d709
Showing 14 changed files with 137 additions and 87 deletions
app/src/main/java/com/cnlive/strike/debug/MainActivity.java
lib_media/src/main/java/com/cnlive/media/frame/view/MediaPickerFragmentView.java
lib_media/src/main/java/com/cnlive/media/frame/view/RecordFragmentView.java
lib_media/src/main/java/com/cnlive/media/media/loader/VideoLoader.java
lib_media/src/main/java/com/cnlive/media/ui/activity/MediaActivity.java
lib_media/src/main/java/com/cnlive/media/ui/fragment/RecordPreviewFragment.java
lib_media/src/main/java/com/cnlive/media/ui/widget/crop/CropUtil.java
lib_media/src/main/java/com/cnlive/media/ui/widget/large/SubsamplingScaleImageView.java
lib_media/src/main/java/com/cnlive/media/utils/GlideCacheUtil.java
lib_media/src/main/java/com/cnlive/media/utils/ThumbnailsUtils.java
lib_media/src/main/res/layout/activity_media_picker.xml
lib_media/src/main/res/layout/fragment_picker.xml
lib_media/src/main/res/layout/fragment_preview.xml
lib_media/src/main/res/layout/media_preview_bottom_bar.xml
@@ -71,7 +71,7 @@ public class MainActivity extends AppCompatActivity implements View.OnClickListe
                         .maxImageSize(25 * 1024 * 1024)
                         .maxVideoSize(100*1024*1024)
                         .isReturnUri(AndroidQUtil.isAndroidQ())
-                        .selectMode(PickerConfig.PICKER_ONLY_ONE_TYPE)
+                        .selectMode(PickerConfig.PICKER_VIDEO)
                         .defaultSelectList(new ArrayList<Media>())
                         .needCamera(true)
                         .builder()
@@ -2,7 +2,6 @@ package com.cnlive.media.frame.view;
  
 import android.os.Build;
 import android.text.TextUtils;
-import android.util.Log;
  
 import androidx.annotation.RequiresApi;
 import androidx.recyclerview.widget.GridLayoutManager;
@@ -12,12 +11,13 @@ import com.bumptech.glide.Glide;
 import com.cnlive.libs.base.util.AlertUtil;
 import com.cnlive.libs.base.util.DoublePressed;
 import com.cnlive.media.PickerConfig;
+import com.cnlive.media.R;
 import com.cnlive.media.media.entity.Folder;
 import com.cnlive.media.media.entity.Media;
 import com.cnlive.media.ui.activity.MediaActivity;
-import com.cnlive.media.ui.fragment.MediaPickerFragment;
 import com.cnlive.media.ui.adapter.MediaAdapter;
 import com.cnlive.media.ui.adapter.OnItemClickListener;
+import com.cnlive.media.ui.fragment.MediaPickerFragment;
 import com.cnlive.media.ui.widget.SpacingDecoration;
 import com.cnlive.media.utils.FileTypeUtil;
 import com.cnlive.media.utils.MediaStringUtils;
@@ -25,11 +25,9 @@ import com.cnlive.media.utils.observable.MediaOpenActivityObservable;
 import com.cnlive.media.utils.observable.MediaOpenInfo;
 import com.cnlive.media.utils.observable.MediaSelectStateObservable;
 import com.cnlive.media.utils.observable.MeidaResultObservable;
-import com.cnlive.media.R;
 import com.hannesdorfmann.mosby3.mvp.MvpView;
  
 import java.util.ArrayList;
-import java.util.List;
  
  
 /**
@@ -62,20 +60,18 @@ public class MediaPickerFragmentView implements MvpView {
         //如果可以确定每个item的高度是固定的，设置这个选项可以提高性能
         mFragment.binding.rv.setHasFixedSize(true);
  
-//        mFragment.binding.rv.addOnScrollListener(new RecyclerView.OnScrollListener() {
-//            @RequiresApi(api = Build.VERSION_CODES.JELLY_BEAN_MR1)
-//            @Override
-//            public void onScrollStateChanged(RecyclerView recyclerView, int newState) {
-//                super.onScrollStateChanged(recyclerView, newState);
-//                if (RecyclerView.SCROLL_STATE_IDLE == newState) {
-//                    Glide.with(recyclerView).resumeRequests();
-//                    Log.e("","");
-//                } else {
-//                    Log.e("","");
-//                    Glide.with(recyclerView).pauseRequests();
-//                }
-//            }
-//        });
+        mFragment.binding.rv.addOnScrollListener(new RecyclerView.OnScrollListener() {
+            @RequiresApi(api = Build.VERSION_CODES.JELLY_BEAN_MR1)
+            @Override
+            public void onScrollStateChanged(RecyclerView recyclerView, int newState) {
+                super.onScrollStateChanged(recyclerView, newState);
+                if (RecyclerView.SCROLL_STATE_IDLE == newState) {
+                    Glide.with(recyclerView).resumeRequests();
+                } else {
+                    Glide.with(recyclerView).pauseRequests();
+                }
+            }
+        });
         mFragment.mMediaAdapter = new MediaAdapter(mFragment.getActivity(), mActivity.showTime, mActivity.mOptions);
         mFragment.binding.rv.setAdapter(mFragment.mMediaAdapter);
  
@@ -60,7 +60,6 @@ public class RecordFragmentView implements MvpView, PLRecordStateListener {
  
     public void initView() {
  
-   Log.e("启动流程","initView");
         if (getActivity().mOptions == null) {
             //Activity 缓存数据失效，一般情况是App被系统回收
             return;
@@ -112,7 +111,6 @@ public class RecordFragmentView implements MvpView, PLRecordStateListener {
                 videoCaceDirPath = getActivity().mOptions.getCachePath();
             }
         }
-        Log.e("启动流程","initView2");
         getActivity().mOptions.setCachePath(videoCaceDirPath);
         recordSetting.setVideoCacheDir(videoCaceDirPath);
  
@@ -275,17 +273,14 @@ public class RecordFragmentView implements MvpView, PLRecordStateListener {
  
     @Override
     public void onDurationTooShort() {
-        Log.e("", "");
     }
  
     @Override
     public void onRecordStarted() {
-        Log.e("", "");
     }
  
     @Override
     public void onSectionRecording(long l, long l1, int i) {
-        Log.e("", "");
     }
  
     @Override
@@ -300,7 +295,6 @@ public class RecordFragmentView implements MvpView, PLRecordStateListener {
  
     @Override
     public void onSectionDecreased(long l, long l1, int i) {
-        Log.e("", "");
     }
  
     @Override
@@ -37,6 +37,7 @@ public class VideoLoader extends LoaderM implements LoaderManager.LoaderCallback
             MediaStore.Files.FileColumns.SIZE,
             MediaStore.Files.FileColumns._ID,
             MediaStore.Files.FileColumns.PARENT,
+            MediaStore.Video.VideoColumns._ID,
             MediaStore.Video.VideoColumns.DURATION};
  
     Context mContext;
@@ -191,6 +191,8 @@ public class MediaActivity extends MvpBindingActivity&lt;MediaView, MediaPresenter,
             ((MediaPickerFragment) currentFragment).setMediaData(list);
             if (mFolderAdapter != null) mFolderAdapter.updateAdapter(list);
         }
+
+        ThumbnailsUtils.getThumbnails(this);
     }
  
  
@@ -117,7 +117,6 @@ public class RecordPreviewFragment extends MvpBindingFragment&lt;RecordPreviewView,
                     startActivity(intent);
                 }
             } catch (Exception e) {
-                Log.e("异常:", e.getMessage());
             }
  
         } else if (v.getId() == R.id.tb_cancel) {
@@ -189,7 +189,6 @@ public class CropUtil {
             System.gc();
             resultPath = file.getAbsolutePath();
         } catch (IOException e) {
-            Log.e("CropUtils", "saveBmp(): savePath = " + savePath + "\nsaveName = " + saveName + "\n保存图片失败：" + e.toString());
         }
         return resultPath;
     }
@@ -1649,7 +1649,6 @@ public class SubsamplingScaleImageView extends View {
                     return new int[]{sWidth, sHeight, exifOrientation};
                 }
             } catch (Exception e) {
-                Log.e(TAG, "Failed to initialise bitmap decoder", e);
                 this.exception = e;
             }
             return null;
@@ -34,9 +34,16 @@ import com.bumptech.glide.request.target.Target;
 import com.cnlive.media.media.entity.Media;
 import com.cnlive.media.R;
  
+import org.reactivestreams.Subscriber;
+import org.reactivestreams.Subscription;
+
 import java.io.File;
 import java.math.BigDecimal;
  
+import io.reactivex.BackpressureStrategy;
+import io.reactivex.Flowable;
+import io.reactivex.FlowableEmitter;
+import io.reactivex.FlowableOnSubscribe;
 import io.reactivex.Observable;
 import io.reactivex.ObservableEmitter;
 import io.reactivex.ObservableOnSubscribe;
@@ -322,7 +329,10 @@ public class GlideCacheUtil {
             }
             if (media.mediaType == 1) {
                 option = option.error(R.drawable.iv_imgload_full_err);
+            }else {
+                option = option.error(R.drawable.iv_imgload_full_err).placeholder(R.drawable.iv_imgload_full_err);
             }
+
             if (AndroidQUtil.isAndroidQ()) {
                 showAndroidQ(context, media.mediaType, mediaUri, view, loading, option);
             } else {
@@ -330,8 +340,14 @@ public class GlideCacheUtil {
                     showNoAndroidQ(context, media.mediaType, media.path, view, loading, option);
 //                    showImageThumbnail(context, media.mediaType, media.id, media.path, view, loading, option);
                 } else if (media.mediaType == 3) {
-//                    showNoAndroidQ(context, media.mediaType, media.path, view, loading, option);
-                    showVideoThumbnail(context, media.mediaType, media.id, media.path, view, loading, option);
+                    if (ThumbnailsUtils.thumbnails.containsKey(media.id + "")) {
+                        Log.e("包含:",ThumbnailsUtils.thumbnails.get(media.id + ""));
+                        showVideoNoAndroidQ(context, media.mediaType, ThumbnailsUtils.thumbnails.get(media.id + ""), view, loading, option);
+                    } else {
+                        showVideoThumbnail(context, media.mediaType, media.id, media.path, view, loading, option);
+//                        showVideoNoAndroidQ(context, media.mediaType, media.path, view, loading, option);
+                    }
+//
                 }
  
             }
@@ -351,7 +367,7 @@ public class GlideCacheUtil {
                 Bitmap bm = contentResolver.loadThumbnail(mediaUri, new Size(100, 100), null);
                 emitter.onNext(bm);
             }
-        }).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Observer<Bitmap>() {
+        }).subscribeOn(Schedulers.computation()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Observer<Bitmap>() {
             @Override
             public void onSubscribe(Disposable d) {
  
@@ -391,97 +407,137 @@ public class GlideCacheUtil {
         });
     }
  
+    private static void showVideoNoAndroidQ(Context context, int mediaType, String path, ImageView view, ProgressBar loading, RequestOptions option) {
+        RequestBuilder rb = Glide.with(context).load(path);
+        rb.listener(new RequestListener() {
+            @Override
+            public boolean onLoadFailed(@Nullable GlideException e, Object model, Target target, boolean isFirstResource) {
+                view.setScaleType(ImageView.ScaleType.CENTER);
+                if (loading != null) loading.setVisibility(View.GONE);
+                return false;
+            }
+
+            @Override
+            public boolean onResourceReady(Object resource, Object model, Target target, DataSource dataSource, boolean isFirstResource) {
+                if (loading != null) loading.setVisibility(View.GONE);
+                return false;
+            }
+        });
+
+        rb.thumbnail(0.05f).apply(option).into(view);
+    }
  
     private static void showNoAndroidQ(Context context, int mediaType, String path, ImageView view, ProgressBar loading, RequestOptions option) {
-        Observable.create(new ObservableOnSubscribe<String>() {
+        RequestBuilder rb = Glide.with(context).load(path);
+        rb.listener(new RequestListener() {
             @Override
-            public void subscribe(ObservableEmitter<String> emitter) throws Exception {
+            public boolean onLoadFailed(@Nullable GlideException e, Object model, Target target, boolean isFirstResource) {
+                view.setScaleType(ImageView.ScaleType.CENTER);
+                if (loading != null) loading.setVisibility(View.GONE);
+                return false;
+            }
  
-                if (TextUtils.isEmpty(path)) {
-                    emitter.onError(new Throwable(""));
+            @Override
+            public boolean onResourceReady(Object resource, Object model, Target target, DataSource dataSource, boolean isFirstResource) {
+                if (loading != null) loading.setVisibility(View.GONE);
+                return false;
+            }
+        });
+
+        rb.thumbnail(0.3f).apply(option).into(view);
+    }
+
+    public static int count = 0;
+
+    private static void showVideoThumbnail(Context context, int mediaType, long id, String path, ImageView view, ProgressBar loading, RequestOptions option) {
+//        Bitmap bm = getVideoThumbnail(context, id + "");
+//        showThumbnail(context, bm, view, loading, option);
+//        // 步骤1：创建被观察者 =  Flowable
+        Flowable.create(new FlowableOnSubscribe<Bitmap>() {
+            @Override
+            public void subscribe(FlowableEmitter<Bitmap> emitter) throws Exception {
+                Bitmap bm = getVideoThumbnail(context, id + "");
+                if (bm != null) {
+                    emitter.onNext(bm);
                 } else {
-                    emitter.onNext(path);
+                    emitter.onError(new Throwable(""));
                 }
  
+//                emitter.onComplete();
             }
-        }).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Observer<String>() {
-            @Override
-            public void onSubscribe(Disposable d) {
+        }, BackpressureStrategy.LATEST)
+                .subscribe(new Subscriber<Bitmap>() {
+                    // 步骤2：创建观察者 =  Subscriber & 建立订阅关系
  
-            }
+                    @Override
+                    public void onSubscribe(Subscription s) {
+//                        s.request(150);
+                    }
  
-            @Override
-            public void onNext(String thumbnails) {
-                RequestBuilder rb = Glide.with(context).load(thumbnails);
-                rb.listener(new RequestListener() {
                     @Override
-                    public boolean onLoadFailed(@Nullable GlideException e, Object model, Target target, boolean isFirstResource) {
-                        view.setScaleType(ImageView.ScaleType.CENTER);
-                        if (loading != null) loading.setVisibility(View.GONE);
-                        return false;
+                    public void onNext(Bitmap thumbnails) {
+                        showThumbnail(context, thumbnails, view, loading, option);
                     }
  
                     @Override
-                    public boolean onResourceReady(Object resource, Object model, Target target, DataSource dataSource, boolean isFirstResource) {
+                    public void onError(Throwable t) {
+                        showNoAndroidQ(context, mediaType, path, view, loading, option);
                         if (loading != null) loading.setVisibility(View.GONE);
-                        return false;
                     }
-                });
-
-                rb.apply(option).into(view);
-            }
  
-            @Override
-            public void onError(Throwable e) {
-                if (loading != null) loading.setVisibility(View.GONE);
-            }
-
-            @Override
-            public void onComplete() {
+                    @Override
+                    public void onComplete() {
+                    }
+                });
  
-            }
-        });
-    }
  
-    private static void showVideoThumbnail(Context context, int mediaType, int id, String path, ImageView view, ProgressBar loading, RequestOptions option) {
         Observable.create(new ObservableOnSubscribe<Bitmap>() {
             @Override
             public void subscribe(ObservableEmitter<Bitmap> emitter) throws Exception {
-                Bitmap bm = null;
-                if (mediaType == 1) {
-                    bm = getImageThumbnail(context, id + "");
-                    emitter.onNext(bm);
-                } else if (mediaType == 3) {
-                    bm = getVideoThumbnail(context, id + "");
-                    emitter.onNext(bm);
-                }
+                count += 1;
+                Log.e("显示测试:", count + "");
+                Bitmap bitmap = getVideoThumbnail(context, id + "");
+                emitter.onNext(bitmap);
+//
+//                Cursor thumbCursor = null;
+//                Bitmap bitmap = null;
+//                    thumbCursor = context.getContentResolver().query(
+//                            MediaStore.Video.Thumbnails.EXTERNAL_CONTENT_URI,
+//                            null, MediaStore.Video.Thumbnails.VIDEO_ID
+//                                    + "=" + id, null, null);
+//                    if (thumbCursor.moveToFirst()) {
+//                        String albumPath = thumbCursor.getString(thumbCursor.getColumnIndex(MediaStore.Video.Thumbnails.DATA));
+//                        Log.e("显示测试地址:", albumPath);
+//                        bitmap = BitmapFactory.decodeFile(albumPath);
+//                        emitter.onNext(bitmap);
+//                    }else {
+//                        emitter.onNext(Bitmap.createBitmap(1,1,Bitmap.Config.RGB_565));
+//                    }
  
  
             }
         }).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Observer<Bitmap>() {
             @Override
             public void onSubscribe(Disposable d) {
-
+                Log.e("显示测试:--->", "onSubscribe:" + count + "");
             }
  
             @Override
             public void onNext(Bitmap thumbnails) {
-                if (thumbnails != null) {
-                    showThumbnail(context, thumbnails, view, loading, option);
-                } else {
-                    showNoAndroidQ(context, mediaType, path, view, loading, option);
-                }
+                Log.e("显示测试:--->", "onNext:" + count + "");
+                showThumbnail(context, thumbnails, view, loading, option);
  
             }
  
             @Override
             public void onError(Throwable e) {
+                showNoAndroidQ(context, mediaType, path, view, loading, option);
                 if (loading != null) loading.setVisibility(View.GONE);
             }
  
             @Override
             public void onComplete() {
-
+                Log.e("显示测试:--->", "onComplete:" + count + "");
             }
         });
     }
@@ -558,6 +614,7 @@ public class GlideCacheUtil {
                             + "=" + videoId, null, null);
             if (thumbCursor.moveToFirst()) {
                 String albumPath = thumbCursor.getString(thumbCursor.getColumnIndex(MediaStore.Video.Thumbnails.DATA));
+                Log.d("缩略图----------------->:","id:"+videoId+"地址:"+ albumPath);
                 bitmap = BitmapFactory.decodeFile(albumPath);
                 return bitmap;
             }
@@ -21,22 +21,21 @@ public class ThumbnailsUtils {
     static HashMap<String, String> thumbnails = new HashMap<String, String>();
  
     public static void getThumbnails(Context context) {
-        String[] projection = {MediaStore.Images.Thumbnails._ID, MediaStore.Images.Thumbnails.IMAGE_ID,
-                MediaStore.Images.Thumbnails.DATA};
+        String[] projection = {MediaStore.Video.Thumbnails._ID, MediaStore.Video.Thumbnails.VIDEO_ID,
+                MediaStore.Video.Thumbnails.DATA};
  
-        Cursor cursor = context.getContentResolver().query(MediaStore.Images.Thumbnails.EXTERNAL_CONTENT_URI, projection, null, null, null);
+        Cursor cursor = context.getContentResolver().query(MediaStore.Video.Thumbnails.EXTERNAL_CONTENT_URI, projection, null, null, null);
         if (cursor == null) return;
         while (cursor.moveToNext()) {
             int _id;
             int image_id;
             String image_path;
-            int _idColumn = cursor.getColumnIndex(MediaStore.Images.Thumbnails._ID);
-            int image_idColumn = cursor.getColumnIndex(MediaStore.Images.Thumbnails.IMAGE_ID);
-            int dataColumn = cursor.getColumnIndex(MediaStore.Images.Thumbnails.DATA);
+            int _idColumn = cursor.getColumnIndex(MediaStore.Video.Thumbnails._ID);
+            int image_idColumn = cursor.getColumnIndex(MediaStore.Video.Thumbnails.VIDEO_ID);
+            int dataColumn = cursor.getColumnIndex(MediaStore.Video.Thumbnails.DATA);
             _id = cursor.getInt(_idColumn);
             image_id = cursor.getInt(image_idColumn);
             image_path = cursor.getString(dataColumn);
-            Log.e("image_path:", _id+"-->"+image_id + "-->" + image_path);
             thumbnails.put(image_id + "", image_path);
         }
  
@@ -11,6 +11,7 @@
             layout="@layout/meidia_picker_actionbar_top" />
  
         <androidx.recyclerview.widget.RecyclerView
+            android:overScrollMode="never"
             android:id="@+id/rv"
             android:layout_above="@+id/footer"
             android:layout_width="match_parent"
@@ -9,6 +9,7 @@
  
  
         <androidx.recyclerview.widget.RecyclerView
+            android:overScrollMode="never"
             android:id="@+id/rv"
             android:layout_above="@+id/footer"
             android:layout_width="match_parent"
@@ -8,6 +8,7 @@
         android:orientation="vertical">
  
         <androidx.viewpager2.widget.ViewPager2
+            android:overScrollMode="never"
             android:layout_below="@+id/top"
             android:id="@+id/viewpager"
             android:layout_width="match_parent"
@@ -6,6 +6,7 @@
     android:background="#60000000">
  
     <androidx.recyclerview.widget.RecyclerView
+        android:overScrollMode="never"
         android:id="@+id/bottom_recycler_view"
         android:layout_width="match_parent"
         android:layout_height="wrap_content"