细节完善

Author: alafighting

library/src/main/java/com/im4j/kakacache/rxjava/core/disk/journal/FIFODiskJournal.java

@@ -1,15 +1,10 @@
 package com.im4j.kakacache.rxjava.core.disk.journal;
 
 import com.im4j.kakacache.rxjava.common.exception.CacheException;
-import com.im4j.kakacache.rxjava.common.exception.NullException;
-import com.im4j.kakacache.rxjava.common.utils.Utils;
 import com.im4j.kakacache.rxjava.core.CacheEntry;
 import com.litesuits.orm.LiteOrm;
 import com.litesuits.orm.db.assit.QueryBuilder;
-import com.litesuits.orm.db.assit.WhereBuilder;
 
-import java.io.IOException;
-import java.util.Collection;
 import java.util.List;
 
 /**

library/src/main/java/com/im4j/kakacache/rxjava/core/disk/journal/UnlimitedDiskJournal.java

@@ -1,7 +1,6 @@
 package com.im4j.kakacache.rxjava.core.disk.journal;
 
 import com.im4j.kakacache.rxjava.common.exception.CacheException;
-import com.im4j.kakacache.rxjava.core.CacheEntry;
 import com.litesuits.orm.LiteOrm;
 
 /**
@@ -14,13 +13,6 @@ public UnlimitedDiskJournal(LiteOrm liteOrm) {
         super(liteOrm);
     }
 
-    @Override
-    public CacheEntry get(String key) {
-        // 有效期造假，可以欺骗不被清理
-        // cacheEntry.setExpiryTime()
-        return super.get(key);
-    }
-
     // 永不清除有效的缓存（过期依旧会被清理）
     @Override
     public String getLoseKey() throws CacheException {

library/src/main/java/com/im4j/kakacache/rxjava/netcache/retrofit/KakaRxCallAdapterFactory.java

@@ -94,7 +94,7 @@ public <R> Observable<?> adapt(Call<R> call) {
             if (ResultData.class.equals(Utils.getRawType(responseType()))) {
                 // 启用缓存
                 CacheInfo info = CacheInfo.get(annotations);
-                LogUtils.log(info);
+                LogUtils.debug(info);
                 if (info.isEnable()) {
                     // 处理缓存
 
@@ -105,7 +105,7 @@ public <R> Observable<?> adapt(Call<R> call) {
                         info.setKey(ByteString.of(key.getBytes()).md5().hex());
                     }
 
-                    LogUtils.log("fileName="+info.getKey());
+                    LogUtils.debug("fileName="+info.getKey());
 
                     if (info.getStrategy() == null) {
                         info.setStrategy(CacheStrategy.FirstCache);

library/src/main/java/com/im4j/kakacache/rxjava/netcache/strategy/CacheStrategy.java

@@ -60,7 +60,7 @@ protected <T> Observable<ResultData<T>> loadCache(String key) {
     protected <T> Observable<ResultData<T>> loadRemote(String key, Observable<T> source) {
         return source.map(it -> {
             LogUtils.debug("loadRemote result="+it);
-            KakaCache.manager().save(key, it).subscribe(status -> LogUtils.log("save status => "+status) );
+            KakaCache.manager().save(key, it).subscribe(status -> LogUtils.debug("save status => "+status) );
             return new ResultData<>(ResultFrom.Remote, key, it);
         });
     }