// Path: app/src/main/java/me/wavever/ganklock/model/bean/GankDaily.java
// @Table(name = "GankDaily")
// public class GankDaily extends Model {
//     @SerializedName(value = "_id")
//     @Column(name = "_id")
//     public String _id;
//     @SerializedName(value = "publishedAt")
//     @Column(name = "publishedAt")
//     public String publishedAt;
//     @SerializedName(value = "title")
//     @Column(name = "title")
//     public String title;
//     @SerializedName(value = "content")
//     @Column(name = "content")
//     public String content;//妹纸图的url
// }
// 
// Path: app/src/main/java/me/wavever/ganklock/model/bean/GankDailyContent.java
// public class GankDailyContent {
// 
//     @SerializedName(value = "error")
//     public String error;
// 
//     @SerializedName(value = "results")
//     public List<GankDaily> results;
// 
// }
// 
// Path: app/src/main/java/me/wavever/ganklock/model/http/GankService.java
// public interface GankService {
//     @GET("day/{date}")
//     Observable<GankContent> getGankData(@Path("date") String date);
// 
//     @GET("history/content/{count}/{page}")
//     Observable<GankDailyContent> getDailyData(@Path("count")int count, @Path("page")int page);
// 
//     @GET("data/福利/{number}/{page}")
//     Observable<GankContent> getGirlData(@Path("number") int number, @Path("page") int page);
// 
//     @GET("category/{}/count/{}/page/{}")
//     Observable<GankContent> searchGankData(@Query("category") String category,@Path("count") int count,@Path("page") int page);
// }
// 
// Path: app/src/main/java/me/wavever/ganklock/model/http/RetrofitUtil.java
// public class RetrofitUtil {
// 
//     private static GankService sService;
//     private static Gson sGson;
//     private static OkHttpClient sOkHttpClient;
// 
//     static {
//         sGson = new GsonBuilder()
//             .excludeFieldsWithModifiers(Modifier.FINAL, Modifier.TRANSIENT, Modifier.STATIC)
//             //.setDateFormat("yyyy-MM-dd'T'HH:mm:ss" + ".SSS'Z'")
//             .setDateFormat("yyyy/MM/dd")
//             .serializeNulls() //导出null值
//             .create();
//         HttpLoggingInterceptor loggingInterceptor = new HttpLoggingInterceptor();
//         loggingInterceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
//         sOkHttpClient = new OkHttpClient.Builder()
//             .addInterceptor(loggingInterceptor)
//             .retryOnConnectionFailure(true)
//             .connectTimeout(15, TimeUnit.SECONDS)
//             .build();
//     }
// 
// 
//     public static GankService getSingleton() {
// 
//         if (sService == null) {
//             synchronized (RetrofitUtil.class) {
//                 if (sService == null) {
//                     String api = GankApi.BASE_URL;
//                     Retrofit retrofit = new Retrofit.Builder()
//                         .baseUrl(api)
//                         .client(sOkHttpClient)
//                         .addConverterFactory(GsonConverterFactory.create(sGson))
//                         .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
//                         .build();
//                     sService = retrofit.create(GankService.class);
//                 }
//             }
//         }
// 
//         return sService;
//     }
// 
// }
// 
// Path: app/src/main/java/me/wavever/ganklock/utils/LogUtil.java
// public class LogUtil {
// 
//     private static final String TAG = "TAG";
// 
//     public static final int VERBOSE = 1;
// 
//     public static final int DEBUG = 2;
// 
//     public static final int INFO = 3;
// 
//     public static final int WRAN = 4;
// 
//     public static final int ERROR = 5;
// 
//     public static final int NOTHING = 6;
// 
//     public static final int LEVEL = VERBOSE;
// 
//     //只需要修改LEVEL的值，就可以自由的控制日志的打印，
//     // 当LEVEL为NOTHING时，就可以屏蔽掉所有的日志
// 
//     public static void v(String message) {
//         if (LEVEL <= VERBOSE) {
//             Log.v(TAG, message);
//         }
//     }
// 
//     public static void d(String message) {
//         if (LEVEL <= DEBUG) {
//             Log.d(TAG,message);
//         }
//     }
// 
//     public static void i(String message) {
//         if (LEVEL <= INFO) {
//             Log.i(TAG,message);
//         }
//     }
// 
//     public static void w(String message) {
//         if (LEVEL <= WRAN) {
//             Log.w(TAG,message);
//         }
//     }
// 
//     public static void e(String message) {
//         if (LEVEL <= ERROR) {
//             Log.e(TAG,message);
//         }
//     }
// 
// }


import com.activeandroid.query.Select;
import java.util.List;
import io.reactivex.Observable;
import io.reactivex.ObservableEmitter;
import io.reactivex.ObservableOnSubscribe;
import io.reactivex.ObservableSource;
import io.reactivex.Observer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
import io.reactivex.functions.Consumer;
import io.reactivex.functions.Function;
import io.reactivex.schedulers.Schedulers;
import me.wavever.ganklock.model.bean.GankDaily;
import me.wavever.ganklock.model.bean.GankDailyContent;
import me.wavever.ganklock.model.http.GankService;
import me.wavever.ganklock.model.http.RetrofitUtil;
import me.wavever.ganklock.utils.LogUtil;
package me.wavever.ganklock.model.data;




/**
 * Created by wavever on 2016/9/1.
 */
public class DailyGankData {

    private static String TAG = DailyGankData.class.getSimpleName() + "-->";

// Path: app/src/main/java/me/wavever/ganklock/model/bean/GankDaily.java
// @Table(name = "GankDaily")
// public class GankDaily extends Model {
//     @SerializedName(value = "_id")
//     @Column(name = "_id")
//     public String _id;
//     @SerializedName(value = "publishedAt")
//     @Column(name = "publishedAt")
//     public String publishedAt;
//     @SerializedName(value = "title")
//     @Column(name = "title")
//     public String title;
//     @SerializedName(value = "content")
//     @Column(name = "content")
//     public String content;//妹纸图的url
// }
// 
// Path: app/src/main/java/me/wavever/ganklock/model/bean/GankDailyContent.java
// public class GankDailyContent {
// 
//     @SerializedName(value = "error")
//     public String error;
// 
//     @SerializedName(value = "results")
//     public List<GankDaily> results;
// 
// }
// 
// Path: app/src/main/java/me/wavever/ganklock/model/http/GankService.java
// public interface GankService {
//     @GET("day/{date}")
//     Observable<GankContent> getGankData(@Path("date") String date);
// 
//     @GET("history/content/{count}/{page}")
//     Observable<GankDailyContent> getDailyData(@Path("count")int count, @Path("page")int page);
// 
//     @GET("data/福利/{number}/{page}")
//     Observable<GankContent> getGirlData(@Path("number") int number, @Path("page") int page);
// 
//     @GET("category/{}/count/{}/page/{}")
//     Observable<GankContent> searchGankData(@Query("category") String category,@Path("count") int count,@Path("page") int page);
// }
// 
// Path: app/src/main/java/me/wavever/ganklock/model/http/RetrofitUtil.java
// public class RetrofitUtil {
// 
//     private static GankService sService;
//     private static Gson sGson;
//     private static OkHttpClient sOkHttpClient;
// 
//     static {
//         sGson = new GsonBuilder()
//             .excludeFieldsWithModifiers(Modifier.FINAL, Modifier.TRANSIENT, Modifier.STATIC)
//             //.setDateFormat("yyyy-MM-dd'T'HH:mm:ss" + ".SSS'Z'")
//             .setDateFormat("yyyy/MM/dd")
//             .serializeNulls() //导出null值
//             .create();
//         HttpLoggingInterceptor loggingInterceptor = new HttpLoggingInterceptor();
//         loggingInterceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
//         sOkHttpClient = new OkHttpClient.Builder()
//             .addInterceptor(loggingInterceptor)
//             .retryOnConnectionFailure(true)
//             .connectTimeout(15, TimeUnit.SECONDS)
//             .build();
//     }
// 
// 
//     public static GankService getSingleton() {
// 
//         if (sService == null) {
//             synchronized (RetrofitUtil.class) {
//                 if (sService == null) {
//                     String api = GankApi.BASE_URL;
//                     Retrofit retrofit = new Retrofit.Builder()
//                         .baseUrl(api)
//                         .client(sOkHttpClient)
//                         .addConverterFactory(GsonConverterFactory.create(sGson))
//                         .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
//                         .build();
//                     sService = retrofit.create(GankService.class);
//                 }
//             }
//         }
// 
//         return sService;
//     }
// 
// }
// 
// Path: app/src/main/java/me/wavever/ganklock/utils/LogUtil.java
// public class LogUtil {
// 
//     private static final String TAG = "TAG";
// 
//     public static final int VERBOSE = 1;
// 
//     public static final int DEBUG = 2;
// 
//     public static final int INFO = 3;
// 
//     public static final int WRAN = 4;
// 
//     public static final int ERROR = 5;
// 
//     public static final int NOTHING = 6;
// 
//     public static final int LEVEL = VERBOSE;
// 
//     //只需要修改LEVEL的值，就可以自由的控制日志的打印，
//     // 当LEVEL为NOTHING时，就可以屏蔽掉所有的日志
// 
//     public static void v(String message) {
//         if (LEVEL <= VERBOSE) {
//             Log.v(TAG, message);
//         }
//     }
// 
//     public static void d(String message) {
//         if (LEVEL <= DEBUG) {
//             Log.d(TAG,message);
//         }
//     }
// 
//     public static void i(String message) {
//         if (LEVEL <= INFO) {
//             Log.i(TAG,message);
//         }
//     }
// 
//     public static void w(String message) {
//         if (LEVEL <= WRAN) {
//             Log.w(TAG,message);
//         }
//     }
// 
//     public static void e(String message) {
//         if (LEVEL <= ERROR) {
//             Log.e(TAG,message);
//         }
//     }
// 
// }


// Path: app/src/main/java/me/wavever/ganklock/model/data/DailyGankData.java
import com.activeandroid.query.Select;
import java.util.List;
import io.reactivex.Observable;
import io.reactivex.ObservableEmitter;
import io.reactivex.ObservableOnSubscribe;
import io.reactivex.ObservableSource;
import io.reactivex.Observer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
import io.reactivex.functions.Consumer;
import io.reactivex.functions.Function;
import io.reactivex.schedulers.Schedulers;
import me.wavever.ganklock.model.bean.GankDaily;
import me.wavever.ganklock.model.bean.GankDailyContent;
import me.wavever.ganklock.model.http.GankService;
import me.wavever.ganklock.model.http.RetrofitUtil;
import me.wavever.ganklock.utils.LogUtil;

package me.wavever.ganklock.model.data;




/**
 * Created by wavever on 2016/9/1.
 */
public class DailyGankData {

    private static String TAG = DailyGankData.class.getSimpleName() + "-->";

    private GankService service = RetrofitUtil.getSingleton();