From 10533481632adad57c969f1e0287885f570a5e42 Mon Sep 17 00:00:00 2001
From: kunfei <gekunfei@live.com>
Date: Sun, 29 Mar 2020 21:24:43 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../legado/app/service/CheckSourceService.kt  | 41 +++++++++++--------
 1 file changed, 23 insertions(+), 18 deletions(-)

diff --git a/app/src/main/java/io/legado/app/service/CheckSourceService.kt b/app/src/main/java/io/legado/app/service/CheckSourceService.kt
index 336dfb18d..0b2b7329f 100644
--- a/app/src/main/java/io/legado/app/service/CheckSourceService.kt
+++ b/app/src/main/java/io/legado/app/service/CheckSourceService.kt
@@ -7,6 +7,7 @@ import io.legado.app.R
 import io.legado.app.base.BaseService
 import io.legado.app.constant.AppConst
 import io.legado.app.constant.IntentAction
+import io.legado.app.data.entities.BookSource
 import io.legado.app.help.AppConfig
 import io.legado.app.help.IntentHelp
 import io.legado.app.help.coroutine.Coroutine
@@ -70,28 +71,32 @@ class CheckSourceService : BaseService() {
         if (processIndex < allIds.size) {
             val sourceUrl = allIds[processIndex]
             App.db.bookSourceDao().getBookSource(sourceUrl)?.let { source ->
-                val webBook = WebBook(source)
-                webBook.searchBook("我的", scope = this, context = searchPool)
-                    .onError(IO) {
-                        source.addGroup("失效")
-                        App.db.bookSourceDao().update(source)
-                    }.onFinally(IO) {
-                        check()
-                        checkedIds.add(sourceUrl)
-                        updateNotification(
-                            checkedIds.size,
-                            getString(R.string.progress_show, checkedIds.size, allIds.size)
-                        )
-                        synchronized(this) {
-                            if (processIndex >= allIds.size + threadCount - 1) {
-                                stopSelf()
-                            }
-                        }
-                    }
+                check(source)
             }
         }
     }
 
+    private fun check(source: BookSource) {
+        val webBook = WebBook(source)
+        webBook.searchBook("我的", scope = this, context = searchPool)
+            .onError(IO) {
+                source.addGroup("失效")
+                App.db.bookSourceDao().update(source)
+            }.onFinally(IO) {
+                check()
+                checkedIds.add(source.bookSourceUrl)
+                updateNotification(
+                    checkedIds.size,
+                    getString(R.string.progress_show, checkedIds.size, allIds.size)
+                )
+                synchronized(this) {
+                    if (processIndex >= allIds.size + threadCount - 1) {
+                        stopSelf()
+                    }
+                }
+            }
+    }
+
     /**
      * 更新通知
      */