repos event db

Author: CarGuo

lib/common/ab/provider/repos/RepositoryEventDbProvider.dart

@@ -1,4 +1,9 @@
+import 'dart:async';
+import 'dart:convert';
+
 import 'package:gsy_github_app_flutter/common/ab/SqlProvider.dart';
+import 'package:gsy_github_app_flutter/common/model/Event.dart';
+import 'package:sqflite/sqflite.dart';
 
 /**
  * 仓库活跃事件表
@@ -17,7 +22,9 @@ class RepositoryEventDbProvider extends BaseDbProvider {
   String fullName;
   String data;
 
-  Map<String, dynamic> toMap() {
+  RepositoryEventDbProvider();
+
+  Map<String, dynamic> toMap(String fullName, String data) {
     Map<String, dynamic> map = {columnFullName: fullName, columnData: data};
     if (id != null) {
       map[columnId] = id;
@@ -32,10 +39,54 @@ class RepositoryEventDbProvider extends BaseDbProvider {
   }
 
   @override
-  tableSqlString() {}
+  tableSqlString() {
+    return tableBaseString(name, columnId) +
+        '''
+        $columnFullName text not null,
+        $columnData text not null)
+      ''';
+  }
 
   @override
   tableName() {
     return name;
   }
+
+  Future _getProvider(Database db, String fullName) async {
+    List<Map<String, dynamic>> maps =
+        await db.query(name, columns: [columnId, columnFullName, columnData], where: "$columnFullName = ?", whereArgs: [fullName]);
+    if (maps.length > 0) {
+      RepositoryEventDbProvider provider = RepositoryEventDbProvider.fromMap(maps.first);
+      return provider;
+    }
+    return null;
+  }
+
+  ///插入到数据库
+  Future insert(String fullName, String dataMapString) async {
+    Database db = await getDataBase();
+    var provider = await _getProvider(db, fullName);
+    if (provider != null) {
+      await db.delete(name, where: "$columnFullName = ?", whereArgs: [fullName]);
+    }
+    return await db.insert(name, toMap(fullName, dataMapString));
+  }
+
+  ///获取事件数据
+  Future<List<Event>> getEvents(String fullName) async {
+    Database db = await getDataBase();
+
+    var provider = await _getProvider(db, fullName);
+    if (provider != null) {
+      List<Event> list = new List();
+      List<dynamic> eventMap = json.decode(provider.data);
+      if (eventMap.length > 0) {
+        for (var item in eventMap) {
+          list.add(Event.fromJson(item));
+        }
+      }
+      return list;
+    }
+    return null;
+  }
 }

lib/common/dao/ReposDao.dart

@@ -7,6 +7,7 @@ import 'package:fluttertoast/fluttertoast.dart';
 import 'package:get_version/get_version.dart';
 import 'package:gsy_github_app_flutter/common/ab/provider/repos/RepositoryDetailDbProvider.dart';
 import 'package:gsy_github_app_flutter/common/ab/provider/repos/RepositoryDetailReadmeDbProvider.dart';
+import 'package:gsy_github_app_flutter/common/ab/provider/repos/RepositoryEventDbProvider.dart';
 import 'package:gsy_github_app_flutter/common/ab/provider/repos/TrendRepositoryDbProvider.dart';
 import 'package:gsy_github_app_flutter/common/config/Config.dart';
 import 'package:gsy_github_app_flutter/common/dao/DaoResult.dart';
@@ -112,22 +113,40 @@ class ReposDao {
   /**
    * 仓库活动事件
    */
-  static getRepositoryEventDao(userName, reposName, {page = 0, branch = "master"}) async {
-    String url = Address.getReposEvent(userName, reposName) + Address.getPageParams("?", page);
-    var res = await HttpManager.netFetch(url, null, null, null);
-    if (res != null && res.result) {
-      List<Event> list = new List();
-      var data = res.data;
-      if (data == null || data.length == 0) {
+  static getRepositoryEventDao(userName, reposName, {page = 0, branch = "master", needDb = false}) async {
+    String fullName = userName + "/" + reposName;
+    RepositoryEventDbProvider provider = new RepositoryEventDbProvider();
+
+    next() async {
+      String url = Address.getReposEvent(userName, reposName) + Address.getPageParams("?", page);
+      var res = await HttpManager.netFetch(url, null, null, null);
+      if (res != null && res.result) {
+        List<Event> list = new List();
+        var data = res.data;
+        if (data == null || data.length == 0) {
+          return new DataResult(null, false);
+        }
+        for (int i = 0; i < data.length; i++) {
+          list.add(Event.fromJson(data[i]));
+        }
+        if (needDb) {
+          provider.insert(fullName, json.encode(data));
+        }
+        return new DataResult(list, true);
+      } else {
         return new DataResult(null, false);
       }
-      for (int i = 0; i < data.length; i++) {
-        list.add(Event.fromJson(data[i]));
+    }
+
+    if (needDb) {
+      List<Event> list = await provider.getEvents(fullName);
+      if (list == null) {
+        return await next();
       }
-      return new DataResult(list, true);
-    } else {
-      return new DataResult(null, false);
+      DataResult dataResult = new DataResult(list, true, next: next());
+      return dataResult;
     }
+    return await next();
   }
 
   /**

lib/page/RepositoryDetailPage.dart

@@ -1,5 +1,3 @@
-import 'dart:async';
-
 import 'package:flutter/material.dart';
 import 'package:gsy_github_app_flutter/common/dao/ReposDao.dart';
 import 'package:gsy_github_app_flutter/common/style/GSYStyle.dart';

lib/page/RepostoryDetailInfoPage.dart

@@ -78,9 +78,20 @@ class ReposDetailInfoPageState extends GSYListState<ReposDetailInfoPage> {
 
   _getDataLogic() async {
     if (selectIndex == 1) {
-      return await ReposDao.getReposCommitsDao(userName, reposName, page: page, branch: reposDetailParentControl.currentBranch);
+      return await ReposDao.getReposCommitsDao(
+        userName,
+        reposName,
+        page: page,
+        branch: reposDetailParentControl.currentBranch,
+      );
     }
-    return await ReposDao.getRepositoryEventDao(userName, reposName, page: page, branch: reposDetailParentControl.currentBranch);
+    return await ReposDao.getRepositoryEventDao(
+      userName,
+      reposName,
+      page: page,
+      branch: reposDetailParentControl.currentBranch,
+      needDb: page <= 1,
+    );
   }
 
   _getReposDetail() {