设计本地缓存类，添加SP工具类

Karl · Karl · commit 2c82db2cb22a · 2017-09-15T01:07:23.000+08:00
diff --git a/app/src/main/AndroidManifest.xml b/app/src/main/AndroidManifest.xml
@@ -3,6 +3,8 @@
     package="com.xiasuhuei321.gank_kotlin">
 
     <uses-permission android:name="android.permission.INTERNET" />
+    <uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE"/>
+    <uses-permission android:name="android.permission.READ_EXTERNAL_STORAGE"/>
 
     <application
         android:name=".GankApplication"
diff --git a/app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/DataSource.kt b/app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/DataSource.kt
@@ -12,7 +12,10 @@ import io.reactivex.Observable
 interface DataSource {
 
     // 获取Data
-    fun getData(type: String): Observable<List<GankData>>
+    fun getRemoteData(type: String): Observable<List<GankData>>
+
+    //获取Data,默认请求数据为10
+    fun getRemoteData(type: String,pageIndex: Int):Observable<List<GankData>>
 
     // 获取服务器数据，每页数据默认为10, 页码默认为1
     fun getRemoteData(type: String, count: Int,pageIndex: Int): Observable<List<GankData>>
diff --git a/app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/DataSourceImpl.kt b/app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/DataSourceImpl.kt
@@ -1,9 +1,6 @@
 package com.xiasuhuei321.gank_kotlin.datasource
 
-import android.util.Log
-import com.xiasuhuei321.gank_kotlin.app
 import com.xiasuhuei321.gank_kotlin.datasource.bean.GankData
-import com.xiasuhuei321.gank_kotlin.datasource.bean.JsonResult
 import com.xiasuhuei321.gank_kotlin.datasource.bean.Weather
 import com.xiasuhuei321.gank_kotlin.datasource.local.LocalDataSource
 import com.xiasuhuei321.gank_kotlin.datasource.local.LocalDataSourceImpl
@@ -12,7 +9,6 @@ import com.xiasuhuei321.gank_kotlin.datasource.remote.RemoteDataSourceImpl
 import com.xiasuhuei321.gank_kotlin.extension.handleResult
 import com.xiasuhuei321.gank_kotlin.extension.io_main
 import io.reactivex.Observable
-import io.reactivex.functions.Function
 
 /**
  * Created by coderFan on 2017/8/11.
@@ -37,44 +33,52 @@ object DataSourceImpl : DataSource {
 
     }
 
-    override fun getData(type: String): Observable<List<GankData>> {
-        return getRemoteData(type,10,1)
+    override fun getRemoteData(type: String): Observable<List<GankData>> {
+        return getRemoteData(type, 10, 1)
+    }
+
+    override fun getRemoteData(type: String, pageIndex: Int): Observable<List<GankData>> {
+        return getRemoteData(type, 10, pageIndex)
     }
 
     override fun getRemoteData(type: String, count: Int, pageIndex: Int): Observable<List<GankData>> {
         return remote
-                .getRemoteData(type,10,1)
+                .getRemoteData(type, 10, 1)
                 .compose(handleResult())
+                .doOnNext({ list ->
+                            if (pageIndex == 1) refreshLocalData(type, list)//只有当加载第一页数据的时候才缓存
+                        }
+                )
                 .io_main()
     }
 
     /**
      * 清除本地指定缓存
      */
     override fun clearData(type: String) {
-        TODO("清除本地指定缓存数据")
+        local.clearLocalData(type)
     }
 
     /**
      * 清除本地所有缓存
      */
     override fun clearAllData() {
-//        TODO("清除本地所有缓存数据")
+        local.clearAllData()
     }
 
 
     /**
      * 优先从本地获取数据
      */
     private fun getLocalData(type: String): Observable<List<GankData>> {
-        TODO("获取本地的缓存数据")
+        return local.getLocalData(type)
     }
 
     /**
      * 刷新本地序列化存储数据
      */
-    private fun refreshLocalData(type: String) {
-//        TODO("序列化存储指定数据到本地")
+    private fun <T> refreshLocalData(type: String, list: Collection<T>) {
+        local.refreshLocalData(type,list)
     }
 
     /**
diff --git a/app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/bean/Code.kt b/app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/bean/Code.kt
@@ -76,3 +76,10 @@ object ResponseCode {
      */
     val SEVER_ERROR = 500
 }
+
+object CacheValues{
+
+    val SP_CONFIG_NAME = "GankKotlin"
+
+    val FILE_NAME = "GankFile"
+}
diff --git a/app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/bean/Data.kt b/app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/bean/Data.kt
@@ -5,17 +5,19 @@ package com.xiasuhuei321.gank_kotlin.datasource.bean
  * desc:数据
  */
 
-data class JsonResult<T>(var error: Boolean, var results: T)
+data class JsonResult<T>(val error: Boolean, val results: T)
 
-data class GankData(var _id: String,
-                    var createAt: String,
-                    var desc: String,
-                    var publishedAt: String,
-                    var source: String,
-                    var type: String,
-                    var url: String,
-                    var used: Boolean,
-                    var who: String)
+data class GankData(val _id: String,
+                    val createAt: String,
+                    val desc: String,
+                    val publishedAt: String,
+                    val source: String,
+                    val type: String,
+                    val url: String,
+                    val used: Boolean,
+                    val who: String){
+    fun create() = createAt.substring(0,10)
+}
 
 
 data class City(val cityName: String,
diff --git a/app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/code/ErrorCode.kt b/app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/code/ErrorCode.kt
diff --git a/app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/code/Type.kt b/app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/code/Type.kt
diff --git a/app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/local/LocalDataSource.kt b/app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/local/LocalDataSource.kt
@@ -13,5 +13,11 @@ interface LocalDataSource {
     //本地缓存
     fun getLocalData(type: String): Observable<List<GankData>>
 
+    fun <T> refreshLocalData(type: String,list: Collection<T>)
+
+    fun clearLocalData(type: String)
+
+    fun clearAllData()
+
     fun json2DB(): Map<String, List<Town>>
 }
diff --git a/app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/local/LocalDataSourceImpl.kt b/app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/local/LocalDataSourceImpl.kt
@@ -6,14 +6,27 @@ import io.reactivex.Observable
 
 /**
  * Created by coderfan on 2017/8/11.
- * desc:
+ * desc:数据缓存管理类
  */
 class LocalDataSourceImpl : LocalDataSource {
+
     override fun json2DB(): Map<String, List<Town>> {
         return null!!
     }
 
     override fun getLocalData(type: String): Observable<List<GankData>> {
-        TODO("not implemented") //To change body of created functions use File | Settings | File Templates.
+        TODO("获取本地缓存的数据，检查缓存、sp/file/db（待定）,取数据需要先本地取数据，然后检查是否有符合的数据") //To change body of created functions use File | Settings | File Templates.
+    }
+
+    override fun <T> refreshLocalData(type: String, list: Collection<T>) {
+        TODO("将数据存到本地,这里传入的list应该先装入Map，然后map转换成json再存入本地") //To change body of created functions use File | Settings | File Templates.
+    }
+
+    override fun clearLocalData(type: String) {
+        TODO("清空本地指定缓存") //To change body of created functions use File | Settings | File Templates.
+    }
+
+    override fun clearAllData() {
+        TODO("清空本地所有缓存") //To change body of created functions use File | Settings | File Templates.
     }
 }
diff --git a/app/src/main/java/com/xiasuhuei321/gank_kotlin/extension/FileExtension.kt b/app/src/main/java/com/xiasuhuei321/gank_kotlin/extension/FileExtension.kt
@@ -0,0 +1,43 @@
+package com.xiasuhuei321.gank_kotlin.extension
+
+import android.os.Environment
+import com.xiasuhuei321.gank_kotlin.GankApplication
+import com.xiasuhuei321.gank_kotlin.context
+import com.xiasuhuei321.gank_kotlin.datasource.bean.CacheValues
+import java.io.File
+import java.io.FileOutputStream
+import java.io.IOException
+import java.io.ObjectOutputStream
+
+/**
+ * Created by CoderFan on 2017/9/15.
+ * desc:File 序列化读写
+ */
+
+/**
+ * 序列化对象
+ */
+@Throws(IOException::class)
+fun <T> setSerializable(t: T) {
+//    if (checkDir()){
+//        val oos:ObjectOutputStream
+//        try {
+//            val file = File(Environment.getExternalStorageDirectory(),CacheValues.FILE_NAME)
+//            if (!file.exists())file.createNewFile()
+//            val fos = FileOutputStream(file)
+//
+//            oos.writeObject(t)
+//        }catch (e:IOException){
+//            e.printStackTrace()
+//        }finally {
+//            oos.close()
+//        }
+//    }
+}
+
+/**
+ * 外部存储路径检查
+ */
+fun checkDir():Boolean{
+    return Environment.getExternalStorageDirectory().equals(Environment.MEDIA_MOUNTED)
+}
diff --git a/app/src/main/java/com/xiasuhuei321/gank_kotlin/extension/JsonExtension.kt b/app/src/main/java/com/xiasuhuei321/gank_kotlin/extension/JsonExtension.kt
@@ -0,0 +1,32 @@
+package com.xiasuhuei321.gank_kotlin.extension
+
+import com.google.gson.GsonBuilder
+import com.google.gson.reflect.TypeToken
+import java.lang.reflect.Type
+
+/**
+ * Created by CoderFan on 2017/9/14.
+ * desc:json转换
+ */
+
+/**
+ * 对象转换成json字符串
+ */
+fun <T> toJson(t:T):String = GsonBuilder().create().toJson(t)
+
+fun <T> listToJson(list: Collection<T>):String = GsonBuilder().create().toJson(list)
+
+fun <K,T> mapToJson(map: HashMap<K,T>):String = GsonBuilder().create().toJson(map)
+
+
+/**
+ * json字符串转换指定类型
+ */
+fun <T> jsonToList(json:String):ArrayList<T>{
+    val type = object:TypeToken<ArrayList<T>>(){}
+    return GsonBuilder().create().fromJson<ArrayList<T>>(json,type.type)
+}
+fun <K,T> jsonToMap(json: String):Map<K,T>{
+    val type = object : TypeToken<Map<K,T>>(){}
+    return GsonBuilder().create().fromJson(json,type.type)
+}
diff --git a/app/src/main/java/com/xiasuhuei321/gank_kotlin/extension/SPExtension.kt b/app/src/main/java/com/xiasuhuei321/gank_kotlin/extension/SPExtension.kt
@@ -0,0 +1,73 @@
+package com.xiasuhuei321.gank_kotlin.extension
+
+import com.xiasuhuei321.gank_kotlin.GankApplication
+import com.xiasuhuei321.gank_kotlin.context
+import com.xiasuhuei321.gank_kotlin.datasource.bean.CacheValues
+
+/**
+ * Created by CoderFan on 2017/9/14.
+ * desc:本地存储
+ */
+
+/**
+ * 存入数据
+ */
+fun <T> putSPValue(key: String, value: T) {
+    val sp = GankApplication.context.getSharedPreferences(CacheValues.SP_CONFIG_NAME, 0x0000)
+    val edit = sp.edit()
+    when (value) {
+        is Boolean -> edit.putBoolean(key, value)
+        is String -> edit.putString(key, value)
+        is Long -> edit.putLong(key, value)
+        is Float -> edit.putFloat(key, value)
+        is Int -> edit.putInt(key, value)
+        else -> throw IllegalArgumentException("u can'y use this type")
+    }
+    edit.apply()
+}
+
+/**
+ * 取出数据
+ */
+fun getSPValues(key: String, default: Any): Any {
+    val sp = GankApplication.context.getSharedPreferences(CacheValues.SP_CONFIG_NAME, 0x0000)
+    return when (default) {
+        is Boolean -> sp.getBoolean(key, default)
+        is String -> sp.getString(key, default)
+        is Long -> sp.getLong(key, default)
+        is Float -> sp.getFloat(key, default)
+        is Int -> sp.getInt(key, default)
+        else -> throw IllegalArgumentException("u can't use this type")
+    }
+}
+
+/**
+ * 检查key是否存在
+ */
+fun checkSPKeys(key: String):Boolean{
+    val sp = GankApplication.context
+            .getSharedPreferences(CacheValues.SP_CONFIG_NAME, 0x0000)
+    return sp.contains(key)
+}
+
+/**
+ * 清除指定数据
+ */
+fun clearSPCache(key: String) {
+    val sp = GankApplication.context
+            .getSharedPreferences(CacheValues.SP_CONFIG_NAME, 0x0000)
+    if (sp.contains(key)){
+        sp.edit().remove(key).apply()
+    }
+}
+
+/**
+ * 清除所有数据
+ */
+fun clearSPCache() = GankApplication.context
+        .getSharedPreferences(CacheValues.SP_CONFIG_NAME, 0x0000)
+        .edit()
+        .clear()
+        .apply()
+
+
