|
|
@ -189,6 +189,8 @@ class CheckSourceService : BaseService() { |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
if (source.hasGroup("搜索失效")) throw NoStackTraceException("搜索失效") |
|
|
|
|
|
|
|
if (source.hasGroup("发现失效")) throw NoStackTraceException("发现失效") |
|
|
|
}.timeout(CheckSource.timeout) |
|
|
|
}.timeout(CheckSource.timeout) |
|
|
|
.onError(searchCoroutine) { |
|
|
|
.onError(searchCoroutine) { |
|
|
|
source.addGroup("失效") |
|
|
|
source.addGroup("失效") |
|
|
@ -204,11 +206,7 @@ class CheckSourceService : BaseService() { |
|
|
|
?.filterNot { |
|
|
|
?.filterNot { |
|
|
|
it.startsWith("Error: ") |
|
|
|
it.startsWith("Error: ") |
|
|
|
}?.joinToString("\n") |
|
|
|
}?.joinToString("\n") |
|
|
|
if (source.hasGroup("搜索失效") || source.hasGroup("发现失效")) { |
|
|
|
Debug.updateFinalMessage(source.bookSourceUrl, "成功") |
|
|
|
Debug.updateFinalMessage(source.bookSourceUrl, "失败") |
|
|
|
|
|
|
|
} else { |
|
|
|
|
|
|
|
Debug.updateFinalMessage(source.bookSourceUrl, "成功") |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
}.onFinally(searchCoroutine) { |
|
|
|
}.onFinally(searchCoroutine) { |
|
|
|
source.respondTime = Debug.getRespondTime(source.bookSourceUrl) |
|
|
|
source.respondTime = Debug.getRespondTime(source.bookSourceUrl) |
|
|
|
appDb.bookSourceDao.update(source) |
|
|
|
appDb.bookSourceDao.update(source) |
|
|
|