pull/94/head
parent
7c2a5b28e7
commit
55c74c7565
@ -0,0 +1,149 @@ |
|||||||
|
package io.legado.app.help.storage |
||||||
|
|
||||||
|
import android.content.Context |
||||||
|
import android.net.Uri |
||||||
|
import androidx.documentfile.provider.DocumentFile |
||||||
|
import io.legado.app.App |
||||||
|
import io.legado.app.data.entities.BookSource |
||||||
|
import io.legado.app.data.entities.ReplaceRule |
||||||
|
import io.legado.app.help.coroutine.Coroutine |
||||||
|
import io.legado.app.utils.DocumentUtils |
||||||
|
import io.legado.app.utils.FileUtils |
||||||
|
import kotlinx.coroutines.Dispatchers |
||||||
|
import kotlinx.coroutines.GlobalScope |
||||||
|
import kotlinx.coroutines.launch |
||||||
|
import kotlinx.coroutines.withContext |
||||||
|
import org.jetbrains.anko.toast |
||||||
|
import java.io.File |
||||||
|
|
||||||
|
object ImportOldData { |
||||||
|
val yueDuPath by lazy { |
||||||
|
FileUtils.getSdCardPath() + File.separator + "YueDu" |
||||||
|
} |
||||||
|
|
||||||
|
fun import(context: Context) { |
||||||
|
GlobalScope.launch(Dispatchers.IO) { |
||||||
|
try {// 导入书架 |
||||||
|
val shelfFile = |
||||||
|
FileUtils.createFileIfNotExist(yueDuPath + File.separator + "myBookShelf.json") |
||||||
|
val json = shelfFile.readText() |
||||||
|
val importCount = importOldBookshelf(json) |
||||||
|
withContext(Dispatchers.Main) { |
||||||
|
context.toast("成功导入书籍${importCount}") |
||||||
|
} |
||||||
|
} catch (e: Exception) { |
||||||
|
withContext(Dispatchers.Main) { |
||||||
|
context.toast("导入书籍失败\n${e.localizedMessage}") |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
try {// Book source |
||||||
|
val sourceFile = |
||||||
|
FileUtils.createFileIfNotExist(yueDuPath + File.separator + "myBookSource.json") |
||||||
|
val json = sourceFile.readText() |
||||||
|
val importCount = importOldSource(json) |
||||||
|
withContext(Dispatchers.Main) { |
||||||
|
context.toast("成功导入书源${importCount}") |
||||||
|
} |
||||||
|
} catch (e: Exception) { |
||||||
|
withContext(Dispatchers.Main) { |
||||||
|
context.toast("导入源失败\n${e.localizedMessage}") |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
try {// Replace rules |
||||||
|
val ruleFile = |
||||||
|
FileUtils.createFileIfNotExist(yueDuPath + File.separator + "myBookReplaceRule.json") |
||||||
|
val json = ruleFile.readText() |
||||||
|
val importCount = importOldReplaceRule(json) |
||||||
|
withContext(Dispatchers.Main) { |
||||||
|
context.toast("成功导入替换规则${importCount}") |
||||||
|
} |
||||||
|
} catch (e: Exception) { |
||||||
|
withContext(Dispatchers.Main) { |
||||||
|
context.toast("导入替换规则失败\n${e.localizedMessage}") |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
fun importUri(uri: Uri) { |
||||||
|
Coroutine.async { |
||||||
|
DocumentFile.fromTreeUri(App.INSTANCE, uri)?.listFiles()?.forEach { |
||||||
|
when (it.name) { |
||||||
|
"myBookShelf.json" -> |
||||||
|
try { |
||||||
|
DocumentUtils.readText(App.INSTANCE, it.uri)?.let { json -> |
||||||
|
val importCount = importOldBookshelf(json) |
||||||
|
withContext(Dispatchers.Main) { |
||||||
|
App.INSTANCE.toast("成功导入书籍${importCount}") |
||||||
|
} |
||||||
|
} |
||||||
|
} catch (e: java.lang.Exception) { |
||||||
|
withContext(Dispatchers.Main) { |
||||||
|
App.INSTANCE.toast("导入书籍失败\n${e.localizedMessage}") |
||||||
|
} |
||||||
|
} |
||||||
|
"myBookSource.json" -> |
||||||
|
try { |
||||||
|
DocumentUtils.readText(App.INSTANCE, it.uri)?.let { json -> |
||||||
|
val importCount = importOldSource(json) |
||||||
|
withContext(Dispatchers.Main) { |
||||||
|
App.INSTANCE.toast("成功导入书源${importCount}") |
||||||
|
} |
||||||
|
} |
||||||
|
} catch (e: Exception) { |
||||||
|
withContext(Dispatchers.Main) { |
||||||
|
App.INSTANCE.toast("导入源失败\n${e.localizedMessage}") |
||||||
|
} |
||||||
|
} |
||||||
|
"myBookReplaceRule.json" -> |
||||||
|
try { |
||||||
|
DocumentUtils.readText(App.INSTANCE, it.uri)?.let { json -> |
||||||
|
val importCount = importOldReplaceRule(json) |
||||||
|
withContext(Dispatchers.Main) { |
||||||
|
App.INSTANCE.toast("成功导入替换规则${importCount}") |
||||||
|
} |
||||||
|
} |
||||||
|
} catch (e: Exception) { |
||||||
|
withContext(Dispatchers.Main) { |
||||||
|
App.INSTANCE.toast("导入替换规则失败\n${e.localizedMessage}") |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
fun importOldBookshelf(json: String): Int { |
||||||
|
val books = OldBook.toNewBook(json) |
||||||
|
App.db.bookDao().insert(*books.toTypedArray()) |
||||||
|
return books.size |
||||||
|
} |
||||||
|
|
||||||
|
fun importOldSource(json: String): Int { |
||||||
|
val bookSources = mutableListOf<BookSource>() |
||||||
|
val items: List<Map<String, Any>> = Restore.jsonPath.parse(json).read("$") |
||||||
|
for (item in items) { |
||||||
|
val jsonItem = Restore.jsonPath.parse(item) |
||||||
|
OldRule.jsonToBookSource(jsonItem.jsonString())?.let { |
||||||
|
bookSources.add(it) |
||||||
|
} |
||||||
|
} |
||||||
|
App.db.bookSourceDao().insert(*bookSources.toTypedArray()) |
||||||
|
return bookSources.size |
||||||
|
} |
||||||
|
|
||||||
|
fun importOldReplaceRule(json: String): Int { |
||||||
|
val replaceRules = mutableListOf<ReplaceRule>() |
||||||
|
val items: List<Map<String, Any>> = Restore.jsonPath.parse(json).read("$") |
||||||
|
for (item in items) { |
||||||
|
val jsonItem = Restore.jsonPath.parse(item) |
||||||
|
OldRule.jsonToReplaceRule(jsonItem.jsonString())?.let { |
||||||
|
replaceRules.add(it) |
||||||
|
} |
||||||
|
} |
||||||
|
App.db.replaceRuleDao().insert(*replaceRules.toTypedArray()) |
||||||
|
return replaceRules.size |
||||||
|
} |
||||||
|
} |
Loading…
Reference in new issue