|
|
@ -6,11 +6,14 @@ import io.legado.app.base.BaseViewModel |
|
|
|
import io.legado.app.data.appDb |
|
|
|
import io.legado.app.data.appDb |
|
|
|
import io.legado.app.data.entities.HttpTTS |
|
|
|
import io.legado.app.data.entities.HttpTTS |
|
|
|
import io.legado.app.data.entities.TxtTocRule |
|
|
|
import io.legado.app.data.entities.TxtTocRule |
|
|
|
|
|
|
|
import io.legado.app.help.ThemeConfig |
|
|
|
import io.legado.app.help.http.newCall |
|
|
|
import io.legado.app.help.http.newCall |
|
|
|
import io.legado.app.help.http.okHttpClient |
|
|
|
import io.legado.app.help.http.okHttpClient |
|
|
|
import io.legado.app.help.http.text |
|
|
|
import io.legado.app.help.http.text |
|
|
|
import io.legado.app.utils.GSON |
|
|
|
import io.legado.app.utils.GSON |
|
|
|
import io.legado.app.utils.fromJsonArray |
|
|
|
import io.legado.app.utils.fromJsonArray |
|
|
|
|
|
|
|
import io.legado.app.utils.fromJsonObject |
|
|
|
|
|
|
|
import io.legado.app.utils.isJsonArray |
|
|
|
|
|
|
|
|
|
|
|
class OnLineImportViewModel(app: App) : BaseViewModel(app) { |
|
|
|
class OnLineImportViewModel(app: App) : BaseViewModel(app) { |
|
|
|
|
|
|
|
|
|
|
@ -19,9 +22,15 @@ class OnLineImportViewModel(app: App) : BaseViewModel(app) { |
|
|
|
okHttpClient.newCall { |
|
|
|
okHttpClient.newCall { |
|
|
|
url(url) |
|
|
|
url(url) |
|
|
|
}.text("utf-8").let { json -> |
|
|
|
}.text("utf-8").let { json -> |
|
|
|
GSON.fromJsonArray<TxtTocRule>(json)?.let { |
|
|
|
if (json.isJsonArray()) { |
|
|
|
appDb.txtTocRuleDao.insert(*it.toTypedArray()) |
|
|
|
GSON.fromJsonArray<TxtTocRule>(json)?.let { |
|
|
|
} ?: throw Exception("格式不对") |
|
|
|
appDb.txtTocRuleDao.insert(*it.toTypedArray()) |
|
|
|
|
|
|
|
} ?: throw Exception("格式不对") |
|
|
|
|
|
|
|
} else { |
|
|
|
|
|
|
|
GSON.fromJsonObject<TxtTocRule>(json)?.let { |
|
|
|
|
|
|
|
appDb.txtTocRuleDao.insert(it) |
|
|
|
|
|
|
|
} ?: throw Exception("格式不对") |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
}.onSuccess { |
|
|
|
}.onSuccess { |
|
|
|
finally.invoke(context.getString(R.string.success), "导入Txt规则成功") |
|
|
|
finally.invoke(context.getString(R.string.success), "导入Txt规则成功") |
|
|
@ -35,10 +44,17 @@ class OnLineImportViewModel(app: App) : BaseViewModel(app) { |
|
|
|
okHttpClient.newCall { |
|
|
|
okHttpClient.newCall { |
|
|
|
url(url) |
|
|
|
url(url) |
|
|
|
}.text("utf-8").let { json -> |
|
|
|
}.text("utf-8").let { json -> |
|
|
|
GSON.fromJsonArray<HttpTTS>(json)?.let { |
|
|
|
if (json.isJsonArray()) { |
|
|
|
appDb.httpTTSDao.insert(*it.toTypedArray()) |
|
|
|
GSON.fromJsonArray<HttpTTS>(json)?.let { |
|
|
|
return@execute it.size |
|
|
|
appDb.httpTTSDao.insert(*it.toTypedArray()) |
|
|
|
} ?: throw Exception("格式不对") |
|
|
|
return@execute it.size |
|
|
|
|
|
|
|
} ?: throw Exception("格式不对") |
|
|
|
|
|
|
|
} else { |
|
|
|
|
|
|
|
GSON.fromJsonObject<HttpTTS>(json)?.let { |
|
|
|
|
|
|
|
appDb.httpTTSDao.insert(it) |
|
|
|
|
|
|
|
return@execute 1 |
|
|
|
|
|
|
|
} ?: throw Exception("格式不对") |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
}.onSuccess { |
|
|
|
}.onSuccess { |
|
|
|
finally.invoke(context.getString(R.string.success), "导入${it}朗读引擎") |
|
|
|
finally.invoke(context.getString(R.string.success), "导入${it}朗读引擎") |
|
|
@ -48,7 +64,25 @@ class OnLineImportViewModel(app: App) : BaseViewModel(app) { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
fun importTheme(url: String, finally: (title: String, msg: String) -> Unit) { |
|
|
|
fun importTheme(url: String, finally: (title: String, msg: String) -> Unit) { |
|
|
|
|
|
|
|
execute { |
|
|
|
|
|
|
|
okHttpClient.newCall { |
|
|
|
|
|
|
|
url(url) |
|
|
|
|
|
|
|
}.text("utf-8").let { json -> |
|
|
|
|
|
|
|
if (json.isJsonArray()) { |
|
|
|
|
|
|
|
GSON.fromJsonArray<ThemeConfig.Config>(json)?.forEach { |
|
|
|
|
|
|
|
ThemeConfig.addConfig(it) |
|
|
|
|
|
|
|
} ?: throw Exception("格式不对") |
|
|
|
|
|
|
|
} else { |
|
|
|
|
|
|
|
GSON.fromJsonObject<ThemeConfig.Config>(json)?.let { |
|
|
|
|
|
|
|
ThemeConfig.addConfig(it) |
|
|
|
|
|
|
|
} ?: throw Exception("格式不对") |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
}.onSuccess { |
|
|
|
|
|
|
|
finally.invoke(context.getString(R.string.success), "导入主题成功") |
|
|
|
|
|
|
|
}.onError { |
|
|
|
|
|
|
|
finally.invoke(context.getString(R.string.error), it.localizedMessage ?: "未知错误") |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
} |