repos commit db

Author: CarGuo

lib/common/ab/provider/repos/RepositoryCommitsDbProvider.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/RepoCommit.dart';
+import 'package:sqflite/sqflite.dart';
 
 /**
  * 仓库提交信息表
@@ -10,14 +15,18 @@ class RepositoryCommitsDbProvider extends BaseDbProvider {
   final String name = 'RepositoryCommits';
   final String columnId = "_id";
   final String columnFullName = "fullName";
+  final String columnBranch = "branch";
   final String columnData = "data";
 
   int id;
   String fullName;
   String data;
+  String branch;
+
+  RepositoryCommitsDbProvider();
 
-  Map<String, dynamic> toMap() {
-    Map<String, dynamic> map = {columnFullName: fullName, columnData: data};
+  Map<String, dynamic> toMap(String fullName, String branch, String data) {
+    Map<String, dynamic> map = {columnFullName: fullName, columnBranch: branch, columnData: data};
     if (id != null) {
       map[columnId] = id;
     }
@@ -27,14 +36,60 @@ class RepositoryCommitsDbProvider extends BaseDbProvider {
   RepositoryCommitsDbProvider.fromMap(Map map) {
     id = map[columnId];
     fullName = map[columnFullName];
+    branch = map[columnBranch];
     data = map[columnData];
   }
 
   @override
-  tableSqlString() {}
+  tableSqlString() {
+    return tableBaseString(name, columnId) +
+        '''
+        $columnFullName text not null,
+        $columnBranch text not null,
+        $columnData text not null)
+      ''';
+  }
 
   @override
   tableName() {
     return name;
   }
-}
+
+  Future _getProvider(Database db, String fullName, String branch) async {
+    List<Map<String, dynamic>> maps = await db.query(name,
+        columns: [columnId, columnFullName, columnBranch, columnData], where: "$columnFullName = ? and $columnBranch = ?", whereArgs: [fullName, branch]);
+    if (maps.length > 0) {
+      RepositoryCommitsDbProvider provider = RepositoryCommitsDbProvider.fromMap(maps.first);
+      return provider;
+    }
+    return null;
+  }
+
+  ///插入到数据库
+  Future insert(String fullName, String branch, String dataMapString) async {
+    Database db = await getDataBase();
+    var provider = await _getProvider(db, fullName, branch);
+    if (provider != null) {
+      await db.delete(name, where: "$columnFullName = ? and $columnBranch = ?", whereArgs: [fullName, branch]);
+    }
+    return await db.insert(name, toMap(fullName, branch, dataMapString));
+  }
+
+  ///获取事件数据
+  Future<List<RepoCommit>> getData(String fullName, String branch) async {
+    Database db = await getDataBase();
+
+    var provider = await _getProvider(db, fullName, branch);
+    if (provider != null) {
+      List<RepoCommit> list = new List();
+      List<dynamic> eventMap = json.decode(provider.data);
+      if (eventMap.length > 0) {
+        for (var item in eventMap) {
+          list.add(RepoCommit.fromJson(item));
+        }
+      }
+      return list;
+    }
+    return null;
+  }
+}

lib/common/dao/ReposDao.dart

@@ -5,6 +5,7 @@ import 'dart:io';
 import 'package:dio/dio.dart';
 import 'package:fluttertoast/fluttertoast.dart';
 import 'package:get_version/get_version.dart';
+import 'package:gsy_github_app_flutter/common/ab/provider/repos/RepositoryCommitsDbProvider.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';
@@ -164,22 +165,41 @@ class ReposDao {
   /**
    * 获取仓库的提交列表
    */
-  static getReposCommitsDao(userName, reposName, {page = 0, branch = "master"}) async {
-    String url = Address.getReposCommits(userName, reposName) + Address.getPageParams("?", page) + "&sha=" + branch;
-    var res = await HttpManager.netFetch(url, null, null, null);
-    if (res != null && res.result) {
-      List<RepoCommit> list = new List();
-      var data = res.data;
-      if (data == null || data.length == 0) {
+  static getReposCommitsDao(userName, reposName, {page = 0, branch = "master", needDb = false}) async {
+    String fullName = userName + "/" + reposName;
+
+    RepositoryCommitsDbProvider provider = new RepositoryCommitsDbProvider();
+
+    next() async {
+      String url = Address.getReposCommits(userName, reposName) + Address.getPageParams("?", page) + "&sha=" + branch;
+      var res = await HttpManager.netFetch(url, null, null, null);
+      if (res != null && res.result) {
+        List<RepoCommit> 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(RepoCommit.fromJson(data[i]));
+        }
+        if (needDb) {
+          provider.insert(fullName, branch, json.encode(data));
+        }
+        return new DataResult(list, true);
+      } else {
         return new DataResult(null, false);
       }
-      for (int i = 0; i < data.length; i++) {
-        list.add(RepoCommit.fromJson(data[i]));
+    }
+
+    if (needDb) {
+      List<RepoCommit> list = await provider.getData(fullName, branch);
+      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/RepostoryDetailInfoPage.dart

@@ -83,6 +83,7 @@ class ReposDetailInfoPageState extends GSYListState<ReposDetailInfoPage> {
         reposName,
         page: page,
         branch: reposDetailParentControl.currentBranch,
+        needDb: page <= 1,
       );
     }
     return await ReposDao.getRepositoryEventDao(