处理添加本地图片预览出错情况

韩亚云
1 parent 78d1c74d
Showing 3 changed files with 71 additions and 64 deletions
app/strike/src/main/java/com/cnlive/strike/imgutil/ImgActivity.java
core/imageload/src/main/java/com/cnlive/core/imageload/preview/presenter/PreviewImgPresenter.java
core/imageload/src/main/java/com/cnlive/core/imageload/preview/presenter/ProcessHtmlPresenter.java
@@ -197,7 +197,6 @@ public class ImgActivity extends AppCompatActivity {
                 @Override
                 public void onDownLoadSuccess(Bitmap bitmap) {
-                    Log.e("sssssss", "onDownLoadSuccess: " );
                     //网络请求
                     bitmaps = bitmap;
                     Message msg = new Message();
@@ -39,62 +39,68 @@ public class PreviewImgPresenter extends BasePresenter&lt;PreviewImgView&gt; {
     public void showImg(Context context, ImagePreviewShowInfo previewData) {
-        Observable.create(new ObservableOnSubscribe<File>() {
-            @Override
-            public void subscribe(ObservableEmitter<File> emitter) {
-                FutureTarget<File> file = Glide.with(context).asFile().load(previewData.getImgPath()).listener(new RequestListener<File>() {
-                    @Override
-                    public boolean onLoadFailed(@Nullable GlideException e, Object model, Target<File> target, boolean isFirstResource) {
+        if(FileUtils.isFileExists(new File(previewData.getImgPath()))){
+            ifViewAttached(view -> view.showResourceReady());
+            ifViewAttached(view -> view.showImg(new File(previewData.getImgPath())));
+        }else {
+            Observable.create(new ObservableOnSubscribe<File>() {
+                @Override
+                public void subscribe(ObservableEmitter<File> emitter) {
+                    FutureTarget<File> file = Glide.with(context).asFile().load(previewData.getImgPath()).listener(new RequestListener<File>() {
+                        @Override
+                        public boolean onLoadFailed(@Nullable GlideException e, Object model, Target<File> target, boolean isFirstResource) {
 //                        ifViewAttached(view -> view.showLoadFail());
-                        return false;
-                    }
+                            return false;
+                        }
-                    @Override
-                    public boolean onResourceReady(File resource, Object model, Target<File> target, DataSource dataSource, boolean isFirstResource) {
+                        @Override
+                        public boolean onResourceReady(File resource, Object model, Target<File> target, DataSource dataSource, boolean isFirstResource) {
 //                        ifViewAttached(view -> view.showResourceReady());
-                        return false;
-                    }
-                }).submit();
-                try {
-                    File imgfile = file.get();
-                    if (FileUtils.isFileExists(imgfile)) {
-                        emitter.onNext(imgfile);
-                    } else {
+                            return false;
+                        }
+                    }).submit();
+                    try {
+                        File imgfile = file.get();
+                        if (FileUtils.isFileExists(imgfile)) {
+                            emitter.onNext(imgfile);
+                        } else {
+                            emitter.onError(new Throwable("加载失败"));
+                        }
+                    } catch (Exception e) {
                         emitter.onError(new Throwable("加载失败"));
                     }
-                } catch (Exception e) {
-                    emitter.onError(new Throwable("加载失败"));
+
                 }
+            }).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Observer<File>() {
-            }
-        }).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Observer<File>() {
+                @Override
+                public void onSubscribe(Disposable d) {
-            @Override
-            public void onSubscribe(Disposable d) {
+                }
-            }
+                @Override
+                public void onNext(File filse) {
-            @Override
-            public void onNext(File filse) {
+                    ifViewAttached(view -> view.showResourceReady());
+                    ifViewAttached(view -> view.showImg(filse));
+                }
-                ifViewAttached(view -> view.showResourceReady());
-                ifViewAttached(view -> view.showImg(filse));
-            }
+                @Override
+                public void onError(Throwable e) {
+                    ifViewAttached(view -> view.showLoadFail());
+                    if (e != null) {
+                        ifViewAttached(view -> view.showMessage(e.getMessage()));
+                    }
-            @Override
-            public void onError(Throwable e) {
-                ifViewAttached(view -> view.showLoadFail());
-                if (e != null) {
-                    ifViewAttached(view -> view.showMessage(e.getMessage()));
                 }
-            }
+                @Override
+                public void onComplete() {
-            @Override
-            public void onComplete() {
+                }
+            });
+        }
-            }
-        });
     }
 }
@@ -93,7 +93,7 @@ public class ProcessHtmlPresenter extends BasePresenter&lt;ProcessHtmlView&gt; {
     public void collectionPic(DataProcessingActivity context, String imagePath) {
         if (context == null && TextUtils.isEmpty(imagePath)) return;
         if (FileUtils.isFileExists(imagePath)) {
-            if (getView() != null) processLocalImag(context, imagePath);
+            ifViewAttached(view -> processLocalImag(context, imagePath));
         } else {
             if (context.previewData != null) collection(context, imagePath, context.previewData);
         }
@@ -161,17 +161,17 @@ public class ProcessHtmlPresenter extends BasePresenter&lt;ProcessHtmlView&gt; {
      * @param url
      */
     public void savePicture(Context context, String url) {
-        if (getView() != null) getView().hideLoading();
+        ifViewAttached(view -> view.hideLoading());
         if (TextUtils.isEmpty(url)) {
-            if (getView() != null) getView().showMessage("非法图片地址");
+            ifViewAttached(view -> view.showMessage("非法图片地址"));
             return;
         }
         if (FileUtils.isFileExists(url)) {
 //            本地图片 做copy操作
-            if (getView() != null) getView().saveLocalImg(url);
+            ifViewAttached(view -> view.saveLocalImg(url));
         } else {
             if (!url.contains("http")) {
-                if (getView() != null) getView().showMessage("非法图片地址");
+                ifViewAttached(view -> view.showMessage("非法图片地址"));
                 return;
             }
             Observable.create(new ObservableOnSubscribe<String>() {
@@ -197,16 +197,16 @@ public class ProcessHtmlPresenter extends BasePresenter&lt;ProcessHtmlView&gt; {
                 @Override
                 public void onNext(String s) {
-                    if (!TextUtils.isEmpty(s) && getView() != null) {
-                        getView().saveLocalImg(s);
+                    if (!TextUtils.isEmpty(s)) {
+                        ifViewAttached(view -> view.saveLocalImg(s));
                     } else {
-                        if (getView() != null) getView().showMessage("数据异常");
+                        ifViewAttached(view -> view.showMessage("数据异常"));
                     }
                 }
                 @Override
                 public void onError(Throwable e) {
-                    if (getView() != null) getView().showMessage(e.getMessage());
+                    ifViewAttached(view -> view.showMessage(e.getMessage()));
                 }
                 @Override
@@ -247,24 +247,26 @@ public class ProcessHtmlPresenter extends BasePresenter&lt;ProcessHtmlView&gt; {
             @Override
             public void onNext(String content) {
-                if (getView() != null) getView().hideLoading();
+                ifViewAttached(view -> view.hideLoading());
                 if (!TextUtils.isEmpty(content)) {
                     if (type.equals("friends")) {
-                        if (getView() != null) getView().forwardFriends(content);
+                        ifViewAttached(view -> view.forwardFriends(content));
                     } else if (type.equals("life")) {
-                        if (getView() != null) getView().forwardLife(content);
+                        ifViewAttached(view -> view.forwardLife(content));
                     } else {
-                        if (getView() != null) getView().showMessage("类型异常");
+                        ifViewAttached(view -> view.showMessage("类型异常"));
                     }
                 } else {
-                    if (getView() != null) getView().showMessage("非法图片地址");
+                    ifViewAttached(view -> view.showMessage("非法图片地址"));
                 }
             }
             @Override
             public void onError(Throwable e) {
-                if (getView() != null) getView().hideLoading();
-                if (getView() != null) getView().showMessage(e.getMessage());
+                ifViewAttached(view -> {
+                    view.hideLoading();
+                    view.showMessage(e.getMessage());
+                });
             }
             @Override
@@ -278,11 +280,11 @@ public class ProcessHtmlPresenter extends BasePresenter&lt;ProcessHtmlView&gt; {
     public void saveVideo(Activity activity, String imgUrl) {
         if (TextUtils.isEmpty(imgUrl)) {
-            if (getView() != null) getView().showMessage("数据异常");
+            ifViewAttached(view -> view.showMessage("数据异常"));
             return;
         }
         if (imgUrl.contains("http")) {
-            if (getView() != null) getView().saveNetVideo(imgUrl);
+            ifViewAttached(view -> view.saveNetVideo(imgUrl));
         } else {
             saveVideo(activity, FileUtils.getFileByPath(imgUrl));
         }
@@ -321,7 +323,7 @@ public class ProcessHtmlPresenter extends BasePresenter&lt;ProcessHtmlView&gt; {
             outputStream.close();
             context.sendBroadcast(new Intent(Intent.ACTION_MEDIA_SCANNER_SCAN_FILE, Uri.parse("file://" + newFile.getAbsolutePath())));
-            getView().showSucessfulMessage("保存成功");
+            ifViewAttached(view -> view.showSucessfulMessage("保存成功"));
             context.finish();
         } catch (Exception e) {
             Log.e("文件保存异常:", "Exception  ", e);
@@ -377,16 +379,16 @@ public class ProcessHtmlPresenter extends BasePresenter&lt;ProcessHtmlView&gt; {
                     public void onNext(String qrContent) {
 //                        if (getView()!=null)getView().hideLoading();
                         if (qrContent != null && qrContent.length() > 0) {
-                            if (getView() != null) getView().processQrContent(qrContent);
+                            ifViewAttached(view -> view.processQrContent(qrContent));
                         } else {
-                            getView().showMessage("未识别二维码");
+                            ifViewAttached(view -> view.showMessage("未识别二维码"));
                         }
                     }
                     @Override
                     public void onError(Throwable e) {
-                        if (getView() != null) getView().hideLoading();
-                        if (getView() != null) getView().showMessage(e.getMessage());
+                        ifViewAttached(view -> view.hideLoading());
+                        ifViewAttached(view -> view.showMessage(e.getMessage()));
                     }
                     @Override