mirror of
https://github.com/stonega/tsacdop
synced 2025-02-18 04:20:37 +01:00
Bug fixed.
This commit is contained in:
parent
ea4ae2925c
commit
b3f10892f4
@ -1058,8 +1058,9 @@ class DBHelper {
|
|||||||
Future<bool> isDownloaded(String url) async {
|
Future<bool> isDownloaded(String url) async {
|
||||||
var dbClient = await database;
|
var dbClient = await database;
|
||||||
List<Map> list = await dbClient.rawQuery(
|
List<Map> list = await dbClient.rawQuery(
|
||||||
"SELECT downloaded FROM Episodes WHERE enclosure_url = ?", [url]);
|
"SELECT id FROM Episodes WHERE enclosure_url = ? AND enclosure_url != media_id",
|
||||||
return list.first['downloaded'] == 'ND' ? false : true;
|
[url]);
|
||||||
|
return list.isNotEmpty;
|
||||||
}
|
}
|
||||||
|
|
||||||
Future<int> saveDownloaded(String url, String id) async {
|
Future<int> saveDownloaded(String url, String id) async {
|
||||||
|
@ -150,8 +150,9 @@ class GroupList extends ChangeNotifier {
|
|||||||
SubscribeItem _currentSubscribeItem = SubscribeItem('', '');
|
SubscribeItem _currentSubscribeItem = SubscribeItem('', '');
|
||||||
SubscribeItem get currentSubscribeItem => _currentSubscribeItem;
|
SubscribeItem get currentSubscribeItem => _currentSubscribeItem;
|
||||||
|
|
||||||
/// Default false, true if subscribe isolate is created.
|
|
||||||
bool _created = false;
|
bool _created = false;
|
||||||
|
|
||||||
|
/// Default false, true if subscribe isolate is created.
|
||||||
bool get created => _created;
|
bool get created => _created;
|
||||||
|
|
||||||
/// Add subsribe item
|
/// Add subsribe item
|
||||||
@ -452,7 +453,6 @@ Future<void> subIsolateEntryPoint(SendPort sendPort) async {
|
|||||||
try {
|
try {
|
||||||
p = RssFeed.parse(response.data);
|
p = RssFeed.parse(response.data);
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
print(e);
|
|
||||||
sendPort.send([item.title, item.url, 6]);
|
sendPort.send([item.title, item.url, 6]);
|
||||||
await Future.delayed(Duration(seconds: 2));
|
await Future.delayed(Duration(seconds: 2));
|
||||||
sendPort.send([item.title, item.url, 4]);
|
sendPort.send([item.title, item.url, 4]);
|
||||||
@ -567,7 +567,7 @@ Future<void> subIsolateEntryPoint(SendPort sendPort) async {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
print(e);
|
print('$e confirm');
|
||||||
sendPort.send([item.title, item.url, 6]);
|
sendPort.send([item.title, item.url, 6]);
|
||||||
await Future.delayed(Duration(seconds: 2));
|
await Future.delayed(Duration(seconds: 2));
|
||||||
sendPort.send([item.title, item.url, 4]);
|
sendPort.send([item.title, item.url, 4]);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user