搭建网络请求框架

YangShuai
1 parent 31cde7c5
Showing 93 changed files with 4175 additions and 99 deletions
app/strike/build.gradle
app/strike/src/main/AndroidManifest.xml
app/strike/src/main/java/com/cnlive/strike/MainActivity.java
app/strike/src/main/java/com/cnlive/strike/MyActivity.java
app/strike/src/main/java/com/cnlive/strike/MyActivityTest1.java
app/strike/src/main/java/com/cnlive/strike/MyApp.java
app/strike/src/main/java/com/cnlive/strike/MyFragment.java
app/strike/src/main/java/com/cnlive/strike/MyFragment1.java
app/strike/src/main/java/com/cnlive/strike/MyFragment1View.java
app/strike/src/main/java/com/cnlive/strike/MyFragmentView.java
app/strike/src/main/java/com/cnlive/strike/MyPresenter.java
app/strike/src/main/java/com/cnlive/strike/MyPresenter1.java
app/strike/src/main/java/com/cnlive/strike/network/api/ApiService.java
app/strike/src/main/java/com/cnlive/strike/network/bean/LetHimNoSeeBean.java
app/strike/src/main/java/com/cnlive/strike/network/bean/TestBean.java
app/strike/src/main/res/layout/activity_main1.xml
app/strike/src/main/res/xml/network_security_config.xml
config.gradle
core/base/src/main/java/com/cnlive/libs/base/application/AppConfig.java → core/base/src/main/java/com/cnlive/core/libs/base/application/AppConfig.java
core/base/src/main/java/com/cnlive/libs/base/application/MyAppGlideModule.java → core/base/src/main/java/com/cnlive/core/libs/base/application/MyAppGlideModule.java
@@ -11,7 +11,7 @@ android {
  
     defaultConfig {
         applicationId "com.cnlive.strike"
-        minSdkVersion 16
+        minSdkVersion 21
         targetSdkVersion 29
         versionCode 1
         versionName "1.0"
@@ -10,6 +10,7 @@
         android:allowBackup="true"
         android:icon="@mipmap/ic_launcher"
         android:label="@string/app_name"
+        android:networkSecurityConfig="@xml/network_security_config"
         android:roundIcon="@mipmap/ic_launcher_round"
         android:supportsRtl="true"
         android:theme="@style/AppTheme">
 package com.cnlive.strike;
  
  
-import android.content.Context;
 import android.content.Intent;
-import android.os.Bundle;
-import android.util.AttributeSet;
+import android.os.Handler;
+import android.util.Log;
 import android.view.View;
  
-import androidx.annotation.NonNull;
-import androidx.annotation.Nullable;
-import androidx.appcompat.app.AppCompatActivity;
+import com.cnlive.core.libs.base.network.manager.SubscriptionManager;
+import com.cnlive.core.network.request.BaseRequest;
+import com.cnlive.core.libs.base.network.BaseResult;
+import com.cnlive.core.libs.base.network.HttpConn;
+import com.cnlive.core.libs.base.network.NetCallBack;
+import com.cnlive.strike.network.api.ApiService;
+import com.cnlive.strike.network.bean.LetHimNoSeeBean;
+import com.cnlive.strike.network.bean.TestBean;
+import com.cnlive.core.libs.base.frame.activity.BaseActivity;
  
-public class MainActivity extends AppCompatActivity {
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
  
+import io.reactivex.ObservableSource;
+import io.reactivex.functions.Function;
+
+public class MainActivity extends BaseActivity {
+
+
+    @Override
+    protected int initLayout() {
+        return R.layout.activity_main;
+    }
  
     @Override
-    protected void onCreate(@Nullable Bundle savedInstanceState) {
-        super.onCreate(savedInstanceState);
-        setContentView(R.layout.activity_main);
-        findViewById(R.id.go_to).setOnClickListener(view ->   startActivity(new Intent(this,MyActivity.class)) );
+    protected void initView() {
+//        findViewById(R.id.go_to).setOnClickListener(view -> startActivity(new Intent(this, MyActivity.class)));
+        findViewById(R.id.go_to).setOnClickListener(new View.OnClickListener() {
+            @Override
+            public void onClick(View v) {
+            startActivity(new Intent(MainActivity.this,MyActivity.class));
+
+            }
+        });
+    }
  
+    @Override
+    protected void onPause() {
+        super.onPause();
+        SubscriptionManager.getInstance().cancelAll();
     }
  
-    @Nullable
     @Override
-    public View onCreateView(@NonNull String name, @NonNull Context context, @NonNull AttributeSet attrs) {
-        return super.onCreateView(name, context, attrs);
+    protected void initData() {
+
     }
 }
 package com.cnlive.strike;
  
  
-import com.cnlive.libs.base.frame.activity.BaseActivity;
+import com.cnlive.core.libs.base.frame.activity.BaseActivity;
  
  
 public class MyActivity extends BaseActivity {
 package com.cnlive.strike;
  
-import com.cnlive.libs.base.frame.activity.BaseActivity;
+import com.cnlive.core.libs.base.frame.activity.BaseActivity;
  
  
 public class MyActivityTest1 extends BaseActivity {
@@ -2,9 +2,18 @@ package com.cnlive.strike;
  
 import android.app.Application;
  
+import com.cnlive.core.libs.base.application.AppConfig;
+
 public class MyApp extends Application {
     @Override
     public void onCreate() {
         super.onCreate();
+        AppConfig.init(this, BuildConfig.APP_ID, BuildConfig.APP_KEY,
+                BuildConfig.APP_SCERET, BuildConfig.SPECIAL_GROUP_MEMBER_LIMIT,
+                BuildConfig.VERSION_AS_DEBUG, "", "",
+                "10514333", "",
+                "", "", "",
+                "", "", "",
+                BuildConfig.BAIDU_MAP_APP_KEY, "");
     }
 }
@@ -3,24 +3,44 @@ package com.cnlive.strike;
  
 import android.content.Intent;
 import android.os.Bundle;
+import android.os.Handler;
+import android.util.Log;
 import android.view.LayoutInflater;
 import android.view.View;
 import android.view.ViewGroup;
+import android.widget.TextView;
  
-import com.cnlive.libs.base.frame.fragment.BaseFragment;
-import com.cnlive.libs.base.util.StatusBarConfig;
+import com.cnlive.core.libs.base.frame.fragment.BaseFragment;
+import com.cnlive.core.libs.base.network.BaseResult;
+import com.cnlive.core.libs.base.network.HttpConn;
+import com.cnlive.core.libs.base.network.NetCallBack;
+import com.cnlive.core.libs.base.util.StatusBarConfig;
+import com.cnlive.core.network.request.BaseRequest;
+import com.cnlive.strike.network.api.ApiService;
+import com.cnlive.strike.network.bean.LetHimNoSeeBean;
+import com.cnlive.strike.network.bean.TestBean;
  
 import androidx.annotation.NonNull;
 import androidx.annotation.Nullable;
  
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
+import io.reactivex.ObservableSource;
+import io.reactivex.functions.Function;
+
  
 public class MyFragment extends BaseFragment<MyFragmentView, MyPresenter> {
     private View view;
+    public TextView textView;
  
     @Nullable
     @Override
     public View onCreateView(@NonNull LayoutInflater inflater, @Nullable ViewGroup container, @Nullable Bundle savedInstanceState) {
         view = inflater.inflate(R.layout.activity_main1, container, false);
+        textView = view.findViewById(R.id.tv1);
         return view;
     }
  
@@ -31,7 +51,58 @@ public class MyFragment extends BaseFragment&lt;MyFragmentView, MyPresenter&gt; {
         view.findViewById(R.id.btn_test).setOnClickListener(new View.OnClickListener() {
             @Override
             public void onClick(View v) {
-                getActivity().startActivity(new Intent(getActivity(), MyActivityTest1.class));
+                //多个请求
+                HttpConn.action(
+                        BaseRequest
+                                .service(ApiService.class)
+                                .getTest(), new NetCallBack<List<TestBean>>() {
+                            @Override
+                            public void onRequestState(int state) {
+
+                            }
+
+                            @Override
+                            public void onSuccess(List<TestBean> data) {
+
+                            }
+
+                            @Override
+                            public void onFailure(String errCode, String errMsg) {
+
+                            }
+                        });
+                Map<String, String> param = new HashMap<>();
+                param.put("sid", "358916");
+                //多个请求
+                HttpConn.action(
+                        BaseRequest.service(ApiService.class)
+                                .getLetHimNoSee(param)
+                                .flatMap(new Function<BaseResult<LetHimNoSeeBean>, ObservableSource<BaseResult<List<TestBean>>>>() {
+                                    @Override
+                                    public ObservableSource<BaseResult<List<TestBean>>> apply(BaseResult<LetHimNoSeeBean> letHimNoSeeBeanBaseResult) throws Exception {
+                                        Log.e(TAG, "apply: " + letHimNoSeeBeanBaseResult.getData().getDoNotletFsids().size());
+                                        return BaseRequest.service(ApiService.class).getTest();
+                                    }
+                                })
+                        , new NetCallBack<List<TestBean>>() {
+                            @Override
+                            public void onRequestState(int state) {
+                                Log.e(TAG, "onRequestState: ");
+                            }
+
+                            @Override
+                            public void onSuccess(List<TestBean> data) {
+                                Log.e(TAG, "onSuccess: " + data.size());
+                            }
+
+                            @Override
+                            public void onFailure(String errCode, String errMsg) {
+                                Log.e(TAG, "onFailure: " + errMsg);
+//                                        textView.setText(errMsg);
+                                getMvpView().setData(errMsg);
+
+                            }
+                        });
             }
         });
     }
 package com.cnlive.strike;
  
  
-import android.content.Intent;
 import android.os.Bundle;
 import android.view.LayoutInflater;
 import android.view.View;
@@ -10,8 +9,8 @@ import android.view.ViewGroup;
 import androidx.annotation.NonNull;
 import androidx.annotation.Nullable;
  
-import com.cnlive.libs.base.frame.fragment.BaseFragment;
-import com.cnlive.libs.base.util.StatusBarConfig;
+import com.cnlive.core.libs.base.frame.fragment.BaseFragment;
+import com.cnlive.core.libs.base.util.StatusBarConfig;
  
  
 public class MyFragment1 extends BaseFragment {
@@ -2,7 +2,7 @@ package com.cnlive.strike;
  
 import android.util.Log;
  
-import com.cnlive.libs.base.frame.view.BaseView;
+import com.cnlive.core.libs.base.frame.view.BaseView;
  
 public class MyFragment1View extends BaseView {
 //    private MyFragment fragment;
 package com.cnlive.strike;
  
-import com.cnlive.libs.base.frame.view.BaseView;
+import com.cnlive.core.libs.base.frame.view.BaseView;
  
 public class MyFragmentView extends BaseView {
     MyFragment fragment;
@@ -9,7 +9,7 @@ public class MyFragmentView extends BaseView {
         this.fragment = fragment;
     }
  
-    public void setData(String msg){
-//        fragment.tx.setText(msg);
+    public void setData(String msg) {
+        fragment.textView.setText(msg);
     }
 }
 package com.cnlive.strike;
  
-import com.cnlive.libs.base.frame.presenter.BasePresenter;
-import com.hannesdorfmann.mosby3.mvp.MvpBasePresenter;
+import com.cnlive.core.libs.base.frame.presenter.BasePresenter;
  
 public class MyPresenter extends BasePresenter<MyFragmentView> {
     public void setData(String msg) {
 package com.cnlive.strike;
  
-import com.cnlive.libs.base.frame.presenter.BasePresenter;
+import com.cnlive.core.libs.base.frame.presenter.BasePresenter;
  
 public class MyPresenter1 extends BasePresenter<MyFragment1View> {
     public void setData1(String msg) {
+package com.cnlive.strike.network.api;
+
+import com.cnlive.core.libs.base.network.BaseResult;
+import com.cnlive.strike.network.bean.LetHimNoSeeBean;
+import com.cnlive.strike.network.bean.TestBean;
+
+import java.util.List;
+import java.util.Map;
+
+import io.reactivex.Observable;
+import retrofit2.http.GET;
+import retrofit2.http.POST;
+import retrofit2.http.QueryMap;
+
+public interface ApiService {
+    @GET("福利/10/1")
+    Observable<BaseResult<List<TestBean>>> getTest();
+
+    @POST("Daren/moment/getDoNotletFsids.action")
+    Observable<BaseResult<LetHimNoSeeBean>> getLetHimNoSee(@QueryMap() Map<String, String> maps);
+}
+package com.cnlive.strike.network.bean;
+
+import java.util.List;
+
+public class LetHimNoSeeBean {
+
+    private List<DoNotletFsidsBean> doNotletFsids;
+
+    public List<DoNotletFsidsBean> getDoNotletFsids() {
+        return doNotletFsids;
+    }
+
+    public void setDoNotletFsids(List<DoNotletFsidsBean> doNotletFsids) {
+        this.doNotletFsids = doNotletFsids;
+    }
+
+    public static class DoNotletFsidsBean {
+        /**
+         * image : http://yweb0.cnliveimg.com/images/headImg/2018/1114/1542164956106_small.jpg
+         * nickName : 峨眉派掌门候选人
+         * userId : 10513196
+         */
+
+        private String image;
+        private String nickName;
+        private String userId;
+
+        public String getImage() {
+            return image;
+        }
+
+        public void setImage(String image) {
+            this.image = image;
+        }
+
+        public String getNickName() {
+            return nickName;
+        }
+
+        public void setNickName(String nickName) {
+            this.nickName = nickName;
+        }
+
+        public String getUserId() {
+            return userId;
+        }
+
+        public void setUserId(String userId) {
+            this.userId = userId;
+        }
+    }
+}
+package com.cnlive.strike.network.bean;
+
+public class TestBean {
+
+    /**
+     * _id : 5ccdbc219d212239df927a93
+     * createdAt : 2019-05-04T16:21:53.523Z
+     * desc : 2019-05-05
+     * publishedAt : 2019-05-04T16:21:59.733Z
+     * source : web
+     * type : 福利
+     * url : http://ww1.sinaimg.cn/large/0065oQSqly1g2pquqlp0nj30n00yiq8u.jpg
+     * used : true
+     * who : lijinshanmx
+     */
+
+    private String _id;
+    private String createdAt;
+    private String desc;
+    private String publishedAt;
+    private String source;
+    private String type;
+    private String url;
+    private boolean used;
+    private String who;
+
+    public String get_id() {
+        return _id;
+    }
+
+    public void set_id(String _id) {
+        this._id = _id;
+    }
+
+    public String getCreatedAt() {
+        return createdAt;
+    }
+
+    public void setCreatedAt(String createdAt) {
+        this.createdAt = createdAt;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+    public void setDesc(String desc) {
+        this.desc = desc;
+    }
+
+    public String getPublishedAt() {
+        return publishedAt;
+    }
+
+    public void setPublishedAt(String publishedAt) {
+        this.publishedAt = publishedAt;
+    }
+
+    public String getSource() {
+        return source;
+    }
+
+    public void setSource(String source) {
+        this.source = source;
+    }
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+
+    public String getUrl() {
+        return url;
+    }
+
+    public void setUrl(String url) {
+        this.url = url;
+    }
+
+    public boolean isUsed() {
+        return used;
+    }
+
+    public void setUsed(boolean used) {
+        this.used = used;
+    }
+
+    public String getWho() {
+        return who;
+    }
+
+    public void setWho(String who) {
+        this.who = who;
+    }
+}
 <?xml version="1.0" encoding="utf-8"?>
 <layout>
  
-    <RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"
+    <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
         xmlns:app="http://schemas.android.com/apk/res-auto"
         xmlns:tools="http://schemas.android.com/tools"
         android:layout_width="match_parent"
@@ -20,5 +20,5 @@
             android:layout_width="wrap_content"
             android:layout_height="wrap_content"
             android:text="测试view" />
-    </RelativeLayout>
+    </LinearLayout>
 </layout>
 \ No newline at end of file
+<?xml version="1.0" encoding="utf-8"?>
+<network-security-config>
+    <base-config cleartextTrafficPermitted="true">
+        <trust-anchors>
+            <certificates src="system" />
+        </trust-anchors>
+    </base-config>
+</network-security-config>
@@ -71,6 +71,10 @@ ext {
             rxjava                  : 'io.reactivex.rxjava2:rxjava:2.2.9',
             rxandroid               : 'io.reactivex.rxjava2:rxandroid:2.1.1',
             rxbinding               : 'com.jakewharton.rxbinding:rxbinding:1.0.1',
+            //rxlifecycle(管理Rxjava)
+            rxlifecycle             :  'com.trello.rxlifecycle3:rxlifecycle:3.1.0',
+            rxlifecycle_android     :  'com.trello.rxlifecycle3:rxlifecycle-android:3.1.0',
+            rxlifecycle_components  :  'com.trello.rxlifecycle3:rxlifecycle-components:3.1.0',
             //Retrofit
             retrofit                : 'com.squareup.retrofit2:retrofit:2.6.0',
             retrofitConverterGson   : 'com.squareup.retrofit2:converter-gson:2.6.0',
@@ -108,10 +112,10 @@ ext {
             library.qmui,
             library.qmui_arch,
             //mvp
-            library.mvp,
-            library.mvp_lce,
-            library.mvp_nullobject_presenter,
-            library.mvp_viewstate,
+//            library.mvp,
+//            library.mvp_lce,
+//            library.mvp_nullobject_presenter,
+//            library.mvp_viewstate,
             //图片加载Glide
             glide.api,
             glide.transformations,
@@ -136,7 +140,8 @@ ext {
             library.okhttp,
             library.okhttpLoggingInterceptor,
             library.greendao,
-
+            //管理rxjava生命周期
+//            library.rx
             router.api,
  
             test.junit,
-package com.cnlive.libs.base.application;
+package com.cnlive.core.libs.base.application;
  
 import android.content.Context;
  
-import com.cnlive.libs.base.util.AppUtil;
-import com.cnlive.libs.base.util.ChannelUtil;
-import com.cnlive.libs.base.util.UUIDUtils;
+import com.cnlive.core.libs.base.util.AppUtil;
+import com.cnlive.core.libs.base.util.ChannelUtil;
+import com.cnlive.core.libs.base.util.UUIDUtils;
  
  
 /**
-package com.cnlive.libs.base.application;
+package com.cnlive.core.libs.base.application;
  
 import com.bumptech.glide.annotation.GlideModule;
 import com.bumptech.glide.module.AppGlideModule;
-package com.cnlive.libs.base.frame.activity;
+package com.cnlive.core.libs.base.frame.activity;
  
  
 import android.annotation.SuppressLint;
@@ -6,6 +6,7 @@ import android.content.Context;
 import android.content.pm.ActivityInfo;
 import android.os.Bundle;
 import android.os.Looper;
+import android.util.Log;
 import android.view.View;
 import android.view.Window;
 import android.view.WindowManager;
@@ -20,9 +21,10 @@ import androidx.core.content.ContextCompat;
 import androidx.databinding.DataBindingUtil;
 import androidx.databinding.ViewDataBinding;
  
-import com.cnlive.libs.base.util.StatusBarConfig;
-import com.cnlive.libs.base.util.StatusBarUtil;
-import com.cnlive.libs.base.util.ActivityCollector;
+import com.cnlive.core.libs.base.network.manager.SubscriptionManager;
+import com.cnlive.core.libs.base.util.StatusBarConfig;
+import com.cnlive.core.libs.base.util.StatusBarUtil;
+import com.cnlive.core.libs.base.util.ActivityCollector;
  
 /**
  * @author ys
@@ -49,6 +51,8 @@ public abstract class BaseActivity extends AppCompatActivity {
         context = this;
         //activity管理
         ActivityCollector.addActivity(this);
+        //创建订阅映射
+        SubscriptionManager.getInstance().setCurrentDisposables(TAG);
         if (!isShowTitle) {
             requestWindowFeature(Window.FEATURE_NO_TITLE);
         }
@@ -210,6 +214,8 @@ public abstract class BaseActivity extends AppCompatActivity {
         super.onDestroy();
         //activity管理
         ActivityCollector.removeActivity(this);
+        //清除所有订阅
+        SubscriptionManager.getInstance().cancel(TAG);
     }
  
     /**
-package com.cnlive.libs.base.frame.activity;
+package com.cnlive.core.libs.base.frame.activity;
  
 import android.os.Bundle;
  
 import androidx.annotation.NonNull;
  
-import com.cnlive.libs.base.util.ReflectUtil;
+import com.cnlive.core.libs.base.util.ReflectUtil;
 import com.hannesdorfmann.mosby3.mvp.MvpPresenter;
 import com.hannesdorfmann.mosby3.mvp.MvpView;
  
-package com.cnlive.libs.base.frame.activity;
+package com.cnlive.core.libs.base.frame.activity;
  
 import android.os.Bundle;
  
@@ -6,7 +6,7 @@ import androidx.annotation.NonNull;
 import androidx.databinding.DataBindingUtil;
 import androidx.databinding.ViewDataBinding;
  
-import com.cnlive.libs.base.util.ReflectUtil;
+import com.cnlive.core.libs.base.util.ReflectUtil;
 import com.hannesdorfmann.mosby3.mvp.MvpPresenter;
 import com.hannesdorfmann.mosby3.mvp.MvpView;
  
@@ -17,7 +17,7 @@ import com.hannesdorfmann.mosby3.mvp.MvpView;
  * @param <D> Databind Page Data
  * @param <T> Databind Activity ViewDataBinding {@link ViewDataBinding}
  */
-public abstract class MvpBindingActivity<V extends MvpView, P extends MvpPresenter<V>, D, T extends ViewDataBinding> extends com.cnlive.libs.base.frame.activity.MvpActivity<V, P> {
+public abstract class MvpBindingActivity<V extends MvpView, P extends MvpPresenter<V>, D, T extends ViewDataBinding> extends MvpActivity<V, P> {
  
     public T binding;
     public D data;
-package com.cnlive.libs.base.frame.fragment;
+package com.cnlive.core.libs.base.frame.fragment;
  
 import android.os.Bundle;
 import android.view.View;
@@ -9,11 +9,11 @@ import androidx.annotation.NonNull;
 import androidx.annotation.Nullable;
 import androidx.core.content.ContextCompat;
  
-import com.cnlive.libs.base.frame.presenter.BasePresenter;
-import com.cnlive.libs.base.frame.view.BaseView;
-import com.cnlive.libs.base.util.ReflectUtil;
-import com.cnlive.libs.base.util.StatusBarConfig;
-import com.cnlive.libs.base.util.StatusBarUtil;
+import com.cnlive.core.libs.base.frame.presenter.BasePresenter;
+import com.cnlive.core.libs.base.util.ReflectUtil;
+import com.cnlive.core.libs.base.frame.view.BaseView;
+import com.cnlive.core.libs.base.util.StatusBarConfig;
+import com.cnlive.core.libs.base.util.StatusBarUtil;
  
 /**
  * 基类fragment
@@ -25,6 +25,7 @@ import com.cnlive.libs.base.util.StatusBarUtil;
 public abstract class BaseFragment<V extends BaseView, P extends BasePresenter<V>> extends com.hannesdorfmann.mosby3.mvp.MvpFragment<V, P> {
     public V view;
     public P presenter;
+    protected final String TAG = this.getClass().getSimpleName();
  
     @Override
     public void onViewCreated(View view, @Nullable Bundle savedInstanceState) {
-package com.cnlive.libs.base.frame.presenter;
+package com.cnlive.core.libs.base.frame.presenter;
  
-import com.cnlive.libs.base.frame.view.BaseView;
+import com.cnlive.core.libs.base.frame.view.BaseView;
 import com.hannesdorfmann.mosby3.mvp.MvpBasePresenter;
  
 public class BasePresenter<V extends BaseView> extends MvpBasePresenter<V> {
-package com.cnlive.libs.base.frame.view;
+package com.cnlive.core.libs.base.frame.view;
  
 import com.hannesdorfmann.mosby3.mvp.MvpView;
  
+package com.cnlive.core.libs.base.network;
+
+/**
+ * 返回参数基类
+ *
+ * @param <T>
+ */
+public class BaseResult<T> {
+    private static final String CODE_SUCCESS = "0";//响应成功的code
+    private String errorCode;
+    private String errorMessage;
+    private T data;
+
+    public boolean isSuccess() {
+        return CODE_SUCCESS.equals(errorCode);
+    }
+
+    public String getErrorCode() {
+        return errorCode;
+    }
+
+    public void setErrorCode(String errorCode) {
+        this.errorCode = errorCode;
+    }
+
+    public String getErrorMessage() {
+        return errorMessage;
+    }
+
+    public void setErrorMessage(String errorMessage) {
+        this.errorMessage = errorMessage;
+    }
+
+    public T getData() {
+        return data;
+    }
+
+    public void setData(T data) {
+        this.data = data;
+    }
+
+//private static int SUCCESS_CODE=000000;//成功的code
+//    private int code;
+//    private String message;
+//    private T results;
+//    private boolean error;
+//
+//    public boolean isSuccess(){
+//        return getCode()==SUCCESS_CODE;
+//    }
+//    public int getCode() {
+//        return code;
+//    }
+//
+//    public void setCode(int code) {
+//        this.code = code;
+//    }
+//
+//    public String getMessage() {
+//        return message;
+//    }
+//
+//    public void setMessage(String message) {
+//        this.message = message;
+//    }
+//
+//    public T getResults() {
+//        return results;
+//    }
+//
+//    public void setResults(T results) {
+//        this.results = results;
+//    }
+//
+//    public boolean isError() {
+//        return error;
+//    }
+//
+//    public void setError(boolean error) {
+//        this.error = error;
+//    }
+//
+//    @Override
+//    public String toString() {
+//        return super.toString();
+//    }
+}
+package com.cnlive.core.libs.base.network;
+
+import android.util.Log;
+
+import com.cnlive.core.libs.base.network.manager.SubscriptionManager;
+
+import io.reactivex.Observable;
+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;
+
+public class HttpConn {
+    public static final int ON_START = 0;
+    public static final int ON_END = 1;
+
+    public static HttpConn create() {
+        return new HttpConn();
+    }
+
+    private static final String EXCEPTION_CODE = "-1";//异常
+
+
+    /**
+     * 统一处理单个请求
+     *
+     * @param observable
+     * @param callBack
+     * @param <T>
+     */
+    public static <T> Disposable action(Observable<BaseResult<T>> observable, final NetCallBack<T> callBack) {
+        Disposable disposable = null;
+        disposable = observable
+                .subscribeOn(Schedulers.io())
+                .observeOn(AndroidSchedulers.mainThread())
+                .doOnSubscribe(new Consumer<Disposable>() {
+                    @Override
+                    public void accept(Disposable disposable) throws Exception {
+                        if (null != callBack) {
+                            callBack.onRequestState(ON_START);
+                        }
+                    }
+                })
+                .doOnNext(new Consumer<BaseResult<T>>() {
+                    @Override
+                    public void accept(BaseResult<T> tBaseResult) throws Exception {
+                        if (null != callBack) {
+                            callBack.onRequestState(ON_END);
+                        }
+                    }
+                })
+                .onErrorReturn(new Function<Throwable, BaseResult<T>>() {
+                    @Override
+                    public BaseResult<T> apply(Throwable throwable) {
+                        Log.e("Sdf", "apply: " + throwable.toString());
+                        if (null != callBack) {
+                            callBack.onFailure(EXCEPTION_CODE, throwable.toString());
+                        }
+                        return null;
+                    }
+                })
+                .subscribe(new Consumer<BaseResult<T>>() {
+                    @Override
+                    public void accept(BaseResult<T> tBaseResponse) {
+                        if (tBaseResponse.isSuccess()) {
+                            if (null != callBack) {
+                                callBack.onSuccess(tBaseResponse.getData());
+                            }
+                        } else {
+                            if (null != callBack) {
+                                callBack.onFailure(tBaseResponse.getErrorCode(), tBaseResponse.getErrorMessage());
+                            }
+                        }
+                    }
+                }, new Consumer<Throwable>() {
+                    @Override
+                    public void accept(Throwable throwable) {
+//                        if (null != callBack) {
+//                            callBack.onFailure(EXCEPTION_CODE, throwable.getMessage());
+//                        }
+//                        Log.e("LinNetError", "单个请求的错误" + throwable.getMessage());
+                    }
+                });
+        if (null != disposable) {
+            SubscriptionManager.getInstance().add(disposable);
+        }
+        return disposable;
+    }
+
+
+}
+package com.cnlive.core.libs.base.network;
+
+public interface NetCallBack<T> {
+    void onRequestState(int state);
+
+
+    /**
+     * 数据请求成功
+     *
+     * @param data 请求到的数据
+     */
+    void onSuccess(T data);
+
+    /**
+     * 数据请求失败
+     */
+    void onFailure(String errCode, String errMsg);
+
+}
+package com.cnlive.core.libs.base.network.manager;
+
+
+import android.text.TextUtils;
+import android.util.Log;
+
+import java.util.HashMap;
+
+import io.reactivex.disposables.CompositeDisposable;
+import io.reactivex.disposables.Disposable;
+
+public class SubscriptionManager {
+    public static SubscriptionManager instance;
+    //    private CompositeDisposable mDisposables;//存放disposable容器
+    public HashMap<String, CompositeDisposable> hashDisposable;
+    public HashMap<Integer, String> hashTag;
+    private String currentClassName;
+
+    /**
+     * 构造函数 new CompositeDisposable对象
+     */
+    public SubscriptionManager() {
+//        if (mDisposables == null) {
+//            mDisposables = new CompositeDisposable();
+//        }
+        if (null == hashDisposable) {
+            hashDisposable = new HashMap<>();
+        }
+        if (null == hashTag) {
+            hashTag = new HashMap<>();
+        }
+    }
+
+    /**
+     * 单例
+     *
+     * @return
+     */
+    public static SubscriptionManager getInstance() {
+        if (instance == null) {
+            synchronized (SubscriptionManager.class) {
+                if (instance == null) {
+                    instance = new SubscriptionManager();
+                }
+            }
+        }
+        return instance;
+    }
+
+    public void setCurrentDisposables(String TAG) {
+        if (null == hashDisposable.get(TAG)) {
+            currentClassName = TAG;
+            hashDisposable.put(TAG, new CompositeDisposable());
+            //存放当前class映射
+            hashTag.put(hashDisposable.size() - 1, TAG);
+        }
+    }
+
+    /**
+     * 取消订阅事件
+     */
+    public void cancel(String TAG) {
+        if (null != hashDisposable && hashDisposable.size() > 0) {
+            if (null != hashDisposable.get(TAG) && hashDisposable.get(TAG).size() > 0) {
+                CompositeDisposable mDisposables = hashDisposable.get(TAG);
+                if (!mDisposables.isDisposed()) {
+                    Log.e(TAG, "cancel: 解除订阅");
+                    mDisposables.clear();
+                }
+            }
+        }
+    }
+
+    /**
+     * 订阅事件加入到CompositeDisposable容器中
+     *
+     * @param disposable 订阅事件
+     */
+    public void add(Disposable disposable) {
+        if (disposable == null) return;
+        if (null != hashDisposable && hashDisposable.size() > 0) {
+            if (!TextUtils.isEmpty(currentClassName)) {
+                if (null != hashDisposable.get(currentClassName)) {
+                    //存放当前activity对应的订阅
+                    hashDisposable.get(currentClassName).add(disposable);
+                    Log.e(currentClassName, "add: 添加订阅");
+                }
+            }
+        }
+    }
+
+//    /**
+//     * 取消订阅事件
+//     *
+//     * @param disposable 订阅事件
+//     */
+//    public void cancel(Disposable disposable) {
+//        if (disposable != null) {
+//            mDisposables.delete(disposable);
+//        }
+//    }
+
+    /**
+     * 清除容器所有
+     */
+    public void cancelAll() {
+        //解除所有订阅
+        if (null != hashDisposable && hashDisposable.size() > 0) {
+            if (null != hashTag && hashTag.size() > 0) {
+                for (int i = 0; i < hashTag.size(); i++) {
+                    if (null != hashTag.get(i)) {
+                        if (null != hashDisposable.get(hashTag.get(i))) {
+                            hashDisposable.get(hashTag.get(i)).clear();
+                        }
+                    }
+                }
+            }
+        }
+    }
+}
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.app.Activity;
  
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.app.Activity;
 import android.app.ActivityManager;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.os.Build;
 import android.os.Environment;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.content.Context;
 import android.content.pm.ApplicationInfo;
@@ -6,7 +6,7 @@ import android.content.pm.PackageManager;
 import android.text.TextUtils;
 import android.util.Log;
  
-import com.cnlive.libs.base.application.AppConfig;
+import com.cnlive.core.libs.base.application.AppConfig;
  
 /**
  * Created by xiansong on 2014/12/26.
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.app.Activity;
 import android.content.Intent;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.util.Base64;
  
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 /**
  * Created by vclub on 15/5/15.
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 public class DoublePressed {
     private static long time_pressed;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.graphics.Bitmap;
 import android.media.MediaMetadataRetriever;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.text.TextUtils;
  
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.content.Context;
 import android.content.pm.PackageManager;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.content.Context;
 import android.os.Looper;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.graphics.Bitmap;
 import android.graphics.BitmapShader;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.content.Context;
 import android.graphics.Bitmap;
@@ -11,9 +11,9 @@ import android.widget.ImageView;
  
 import com.bumptech.glide.request.RequestOptions;
 import com.bumptech.glide.request.target.ViewTarget;
-import com.cnlive.libs.base.application.GlideApp;
-import com.cnlive.libs.base.application.GlideRequest;
-import com.cnlive.libs.base.application.GlideRequests;
+import com.cnlive.core.libs.base.application.GlideApp;
+import com.cnlive.core.libs.base.application.GlideRequest;
+import com.cnlive.core.libs.base.application.GlideRequests;
  
 public class GlideUtil {
  
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import com.google.gson.Gson;
 import com.google.gson.JsonArray;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.app.Activity;
 import android.content.Context;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.util.Log;
  
-import com.cnlive.libs.base.application.AppConfig;
+import com.cnlive.core.libs.base.application.AppConfig;
  
 public class LogUtil {
     private static boolean ENABLED = AppConfig.isDebug();
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import java.io.File;
 import java.io.FileInputStream;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.content.Context;
 import android.net.ConnectivityManager;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.content.Context;
 import android.graphics.Bitmap;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.content.Context;
 import android.os.Handler;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
  
 import android.util.Log;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.content.Context;
 import android.view.WindowManager;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.content.Context;
 import android.content.pm.PackageInfo;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.content.Context;
 import android.content.SharedPreferences;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 public class StatusBarConfig {
     public static final int WHITE = 0;//白色
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.annotation.TargetApi;
 import android.app.Activity;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.annotation.TargetApi;
 import android.nfc.NdefRecord;
@@ -7,7 +7,6 @@ import android.text.TextPaint;
 import android.util.Base64;
 import android.util.Log;
  
-import java.io.UnsupportedEncodingException;
 import java.net.URLDecoder;
 import java.net.URLEncoder;
 import java.nio.charset.Charset;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.os.Handler;
 import android.os.Message;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.annotation.SuppressLint;
 import android.content.Context;
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 /**
  * 作者: 吴奎庆
-package com.cnlive.libs.base.util;
+package com.cnlive.core.libs.base.util;
  
 import android.app.Activity;
 import android.text.TextUtils;
+/*
+ * Copyright 2017 Hannes Dorfmann.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package com.hannesdorfmann.mosby3;
+
+import android.os.Build;
+import android.util.ArrayMap;
+
+import androidx.annotation.NonNull;
+import androidx.annotation.Nullable;
+import androidx.annotation.RequiresApi;
+
+import com.hannesdorfmann.mosby3.mvp.MvpPresenter;
+import com.hannesdorfmann.mosby3.mvp.MvpView;
+import java.util.Map;
+
+/**
+ * This class basically represents a Map for View Id to the Presenter / ViewState.
+ * One instance of this class is also associated by {@link PresenterManager} to one Activity (kept
+ * across screen orientation changes)
+ *
+ * @author Hannes Dorfmann
+ * @since 3.0.0
+ */
+@RequiresApi(api = Build.VERSION_CODES.KITKAT)
+class ActivityScopedCache {
+
+  private final Map<String, PresenterHolder> presenterMap = new ArrayMap<>();
+
+  ActivityScopedCache() {
+    // package private
+  }
+
+  public void clear() {
+    /*
+    // TODO: can this check if there are still Presenters in the internal cache that must be detached? Maybe post() / postDelayed() on the  MainThreadLooper()
+    // it doesnt work out that well, because super.onDestroy() which then invokes PresenterManager.clear() might be called before the MviDelegates did their job to remove the Presenter from cache and detach the view permanently
+
+    for (PresenterHolder holder : presenterMap.values()) {
+      // This should never be the case: If there were some presenters left in the internal cache,
+      // a delegate didn't work correctly as expected
+      if (holder.presenter != null) {
+        holder.presenter.detachView(false);
+        if (PresenterManager.DEBUG) {
+          Log.w(PresenterManager.DEBUG_TAG,
+              "Found a Presenter that is still alive. This should never happen. It seems that a MvpDelegate / MviDelegate didn't work correctly because this Delegate should have removed the presenter. The Presenter was "
+                  + holder.presenter);
+        }
+      }
+    }
+    */
+    presenterMap.clear();
+  }
+
+  /**
+   * Get the Presenter for a given {@link MvpView} if exists or <code>null</code>
+   *
+   * @param viewId The mosby internal view id
+   * @param <P> The type tof the {@link MvpPresenter}
+   * @return The Presenter for the given view id or <code>null</code>
+   */
+  @Nullable
+  public <P> P getPresenter(@NonNull String viewId) {
+    PresenterHolder holder = presenterMap.get(viewId);
+    return holder == null ? null : (P) holder.presenter;
+  }
+
+  /**
+   * Get the ViewState for a given {@link MvpView} if exists or <code>null</code>
+   *
+   * @param viewId The mosby internal view id
+   * @param <VS> The type tof the {@link MvpPresenter}
+   * @return The ViewState for the given view id or <code>null</code>
+   */
+  @Nullable public <VS> VS getViewState(@NonNull String viewId) {
+    PresenterHolder holder = presenterMap.get(viewId);
+    return holder == null ? null : (VS) holder.viewState;
+  }
+
+  /**
+   * Put the presenter in the internal cache
+   *
+   * @param viewId The mosby internal View id of the {@link MvpView} which the presenter is
+   * associated to.
+   * @param presenter The Presenter
+   */
+  public void putPresenter(@NonNull String viewId,
+      @NonNull MvpPresenter<? extends MvpView> presenter) {
+
+    if (viewId == null) {
+      throw new NullPointerException("ViewId is null");
+    }
+
+    if (presenter == null) {
+      throw new NullPointerException("Presenter is null");
+    }
+
+    PresenterHolder presenterHolder = presenterMap.get(viewId);
+    if (presenterHolder == null) {
+      presenterHolder = new PresenterHolder();
+      presenterHolder.presenter = presenter;
+      presenterMap.put(viewId, presenterHolder);
+    } else {
+      presenterHolder.presenter = presenter;
+    }
+  }
+
+
+  /**
+   * Put the viewstate in the internal cache
+   *
+   * @param viewId The mosby internal View id of the {@link MvpView} which the presenter is
+   * associated to.
+   * @param viewState The Viewstate
+   */
+  public void putViewState(@NonNull String viewId,
+      @NonNull Object viewState) {
+
+    if (viewId == null) {
+      throw new NullPointerException("ViewId is null");
+    }
+
+    if (viewState == null) {
+      throw new NullPointerException("ViewState is null");
+    }
+
+    PresenterHolder presenterHolder = presenterMap.get(viewId);
+    if (presenterHolder == null) {
+      presenterHolder = new PresenterHolder();
+      presenterHolder.viewState = viewState;
+      presenterMap.put(viewId, presenterHolder);
+    } else {
+      presenterHolder.viewState = viewState;
+    }
+  }
+
+  /**
+   * Removes the Presenter (and ViewState) from the internal storage
+   *
+   * @param viewId The msoby internal view id
+   */
+  public void remove(@NonNull String viewId) {
+
+    if (viewId == null) {
+      throw new NullPointerException("View Id is null");
+    }
+
+    presenterMap.remove(viewId);
+  }
+
+  /**
+   * Internal config change Cache entry
+   */
+  static final class PresenterHolder {
+    private MvpPresenter<?> presenter;
+    private Object viewState; // workaround: didn't want to introduce dependency to viewstate module
+  }
+}
+/*
+ * Copyright 2016 Hannes Dorfmann.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+package com.hannesdorfmann.mosby3;
+
+import android.os.Build;
+import android.os.Parcel;
+import android.os.Parcelable;
+import android.view.AbsSavedState;
+
+import androidx.annotation.RequiresApi;
+import androidx.core.os.ParcelableCompat;
+import androidx.core.os.ParcelableCompatCreatorCallbacks;
+
+/**
+ * The SavedState implementation to store the view's internal id to
+ *
+ * @author Hannes Dorfmann
+ * @since 3.0
+ */
+public class MosbySavedState extends AbsSavedState {
+
+  public static final Creator<MosbySavedState> CREATOR =
+      ParcelableCompat.newCreator(new ParcelableCompatCreatorCallbacks<MosbySavedState>() {
+        public MosbySavedState createFromParcel(Parcel in, ClassLoader loader) {
+          if (loader == null) {
+            loader = MosbySavedState.class.getClassLoader();
+          }
+          return new MosbySavedState(in, loader);
+        }
+
+        public MosbySavedState[] newArray(int size) {
+          return new MosbySavedState[size];
+        }
+      });
+
+  private String mosbyViewId;
+
+  public MosbySavedState(Parcelable superState, String mosbyViewId) {
+    super(superState);
+    this.mosbyViewId = mosbyViewId;
+  }
+
+  protected MosbySavedState(Parcel in, ClassLoader loader) {
+    super(in, loader);
+    this.mosbyViewId = in.readString();
+  }
+
+  @Override public void writeToParcel(Parcel out, int flags) {
+    super.writeToParcel(out, flags);
+    out.writeString(mosbyViewId);
+  }
+
+  public String getMosbyViewId() {
+    return mosbyViewId;
+  }
+
+}
+package com.hannesdorfmann.mosby3;
+
+import android.app.Activity;
+import android.app.Application;
+import android.content.Context;
+import android.content.ContextWrapper;
+import android.os.Build;
+import android.os.Bundle;
+import android.util.ArrayMap;
+import android.util.Log;
+import android.view.View;
+
+import androidx.annotation.MainThread;
+import androidx.annotation.NonNull;
+import androidx.annotation.Nullable;
+import androidx.annotation.RequiresApi;
+
+import com.hannesdorfmann.mosby3.mvp.MvpPresenter;
+import com.hannesdorfmann.mosby3.mvp.MvpView;
+import java.util.Map;
+import java.util.UUID;
+
+/**
+ * A internal class responsible to save internal presenter instances during screen orientation
+ * changes and reattach the presenter afterwards.
+ *
+ * <p>
+ * The idea is that each MVP View (like a Activity, Fragment, ViewGroup) will get a unique view id.
+ * This view id is
+ * used to store the presenter and viewstate in it. After screen orientation changes we can reuse
+ * the presenter and viewstate by querying for the given view id (must be saved in view's state
+ * somehow).
+ * </p>
+ *
+ * @author Hannes Dorfmann
+ * @since 3.0
+ */
+@RequiresApi(api = Build.VERSION_CODES.KITKAT)
+final public class PresenterManager {
+
+  public static boolean DEBUG = false;
+  public static final String DEBUG_TAG = "PresenterManager";
+  final static String KEY_ACTIVITY_ID = "com.hannesdorfmann.mosby3.MosbyPresenterManagerActivityId";
+
+  private final static Map<Activity, String> activityIdMap = new ArrayMap<>();
+  private final static Map<String, ActivityScopedCache> activityScopedCacheMap = new ArrayMap<>();
+
+  static final Application.ActivityLifecycleCallbacks activityLifecycleCallbacks =
+      new Application.ActivityLifecycleCallbacks() {
+        @Override public void onActivityCreated(Activity activity, Bundle savedInstanceState) {
+          if (savedInstanceState != null) {
+            String activityId = savedInstanceState.getString(KEY_ACTIVITY_ID);
+            if (activityId != null) {
+              // After a screen orientation change we map the newly created Activity to the same
+              // Activity ID as the previous activity has had (before screen orientation change)
+              activityIdMap.put(activity, activityId);
+            }
+          }
+        }
+
+        @Override public void onActivitySaveInstanceState(Activity activity, Bundle outState) {
+          // Save the activityId into bundle so that the other
+          String activityId = activityIdMap.get(activity);
+          if (activityId != null) {
+            outState.putString(KEY_ACTIVITY_ID, activityId);
+          }
+        }
+
+        @Override public void onActivityStarted(Activity activity) {
+        }
+
+        @Override public void onActivityResumed(Activity activity) {
+        }
+
+        @Override public void onActivityPaused(Activity activity) {
+
+        }
+
+        @Override public void onActivityStopped(Activity activity) {
+        }
+
+        @Override public void onActivityDestroyed(Activity activity) {
+          if (!activity.isChangingConfigurations()) {
+            // Activity will be destroyed permanently, so reset the cache
+            String activityId = activityIdMap.get(activity);
+            if (activityId != null) {
+              ActivityScopedCache scopedCache = activityScopedCacheMap.get(activityId);
+              if (scopedCache != null) {
+                scopedCache.clear();
+                activityScopedCacheMap.remove(activityId);
+              }
+
+              // No Activity Scoped cache available, so unregister
+              if (activityScopedCacheMap.isEmpty()) {
+                // All Mosby related activities are destroyed, so we can remove the activity lifecylce listener
+                activity.getApplication()
+                    .unregisterActivityLifecycleCallbacks(activityLifecycleCallbacks);
+                if (DEBUG) {
+                  Log.d(DEBUG_TAG, "Unregistering ActivityLifecycleCallbacks");
+                }
+              }
+            }
+          }
+          activityIdMap.remove(activity);
+        }
+      };
+
+  private PresenterManager() {
+    throw new RuntimeException("Not instantiatable!");
+  }
+
+  /**
+   * Get an already existing {@link ActivityScopedCache} or creates a new one if not existing yet
+   *
+   * @param activity The Activitiy for which you want to get the activity scope for
+   * @return The {@link ActivityScopedCache} for the given Activity
+   */
+  @NonNull
+  @MainThread
+  static ActivityScopedCache getOrCreateActivityScopedCache(
+      @NonNull Activity activity) {
+    if (activity == null) {
+      throw new NullPointerException("Activity is null");
+    }
+
+    String activityId = activityIdMap.get(activity);
+    if (activityId == null) {
+      // Activity not registered yet
+      activityId = UUID.randomUUID().toString();
+      activityIdMap.put(activity, activityId);
+
+      if (activityIdMap.size() == 1) {
+        // Added the an Activity for the first time so register Activity LifecycleListener
+        activity.getApplication().registerActivityLifecycleCallbacks(activityLifecycleCallbacks);
+        if (DEBUG) {
+          Log.d(DEBUG_TAG, "Registering ActivityLifecycleCallbacks");
+        }
+      }
+    }
+
+    ActivityScopedCache activityScopedCache = activityScopedCacheMap.get(activityId);
+    if (activityScopedCache == null) {
+      activityScopedCache = new ActivityScopedCache();
+      activityScopedCacheMap.put(activityId, activityScopedCache);
+    }
+
+    return activityScopedCache;
+  }
+
+  /**
+   * Get the  {@link ActivityScopedCache} for the given Activity or <code>null</code> if no {@link
+   * ActivityScopedCache} exists for the given Activity
+   *
+   * @param activity The activity
+   * @return The {@link ActivityScopedCache} or null
+   * @see #getOrCreateActivityScopedCache(Activity)
+   */
+  @Nullable
+  @MainThread static ActivityScopedCache getActivityScope(@NonNull Activity activity) {
+    if (activity == null) {
+      throw new NullPointerException("Activity is null");
+    }
+    String activityId = activityIdMap.get(activity);
+    if (activityId == null) {
+      return null;
+    }
+
+    return activityScopedCacheMap.get(activityId);
+  }
+
+  /**
+   * Get the presenter for the View with the given (Mosby - internal) view Id or <code>null</code>
+   * if no presenter for the given view (via view id) exists.
+   *
+   * @param activity The Activity (used for scoping)
+   * @param viewId The mosby internal View Id (unique among all {@link MvpView}
+   * @param <P> The Presenter type
+   * @return The Presenter or <code>null</code>
+   */
+  @Nullable public static <P> P getPresenter(@NonNull Activity activity, @NonNull String viewId) {
+    if (activity == null) {
+      throw new NullPointerException("Activity is null");
+    }
+
+    if (viewId == null) {
+      throw new NullPointerException("View id is null");
+    }
+
+    ActivityScopedCache scopedCache = getActivityScope(activity);
+    return scopedCache == null ? null : (P) scopedCache.getPresenter(viewId);
+  }
+
+  /**
+   * Get the ViewState (see mosby viestate modlue) for the View with the given (Mosby - internal)
+   * view Id or <code>null</code>
+   * if no viewstate for the given view exists.
+   *
+   * @param activity The Activity (used for scoping)
+   * @param viewId The mosby internal View Id (unique among all {@link MvpView}
+   * @param <VS> The type of the ViewState type
+   * @return The Presenter or <code>null</code>
+   */
+  @Nullable public static <VS> VS getViewState(@NonNull Activity activity, @NonNull String viewId) {
+    if (activity == null) {
+      throw new NullPointerException("Activity is null");
+    }
+
+    if (viewId == null) {
+      throw new NullPointerException("View id is null");
+    }
+
+    ActivityScopedCache scopedCache = getActivityScope(activity);
+    return scopedCache == null ? null : (VS) scopedCache.getViewState(viewId);
+  }
+
+  /**
+   * Get the Activity of a context. This is typically used to determine the hosting activity of a
+   * {@link View}
+   *
+   * @param context The context
+   * @return The Activity or throws an Exception if Activity couldnt be determined
+   */
+  @NonNull public static Activity getActivity(@NonNull Context context) {
+    if (context == null) {
+      throw new NullPointerException("context == null");
+    }
+    if (context instanceof Activity) {
+      return (Activity) context;
+    }
+
+    while (context instanceof ContextWrapper) {
+      if (context instanceof Activity) {
+        return (Activity) context;
+      }
+      context = ((ContextWrapper) context).getBaseContext();
+    }
+    throw new IllegalStateException("Could not find the surrounding Activity");
+  }
+
+  /**
+   * Clears the internal (static) state. Used for testing.
+   */
+  static void reset() {
+    activityIdMap.clear();
+    for (ActivityScopedCache scopedCache : activityScopedCacheMap.values()) {
+      scopedCache.clear();
+    }
+
+    activityScopedCacheMap.clear();
+  }
+
+  /**
+   * Puts the presenter into the internal cache
+   *
+   * @param activity The parent activity
+   * @param viewId the view id (mosby internal)
+   * @param presenter the presenter
+   */
+  public static void putPresenter(@NonNull Activity activity, @NonNull String viewId,
+      @NonNull MvpPresenter<? extends MvpView> presenter) {
+    if (activity == null) {
+      throw new NullPointerException("Activity is null");
+    }
+
+    ActivityScopedCache scopedCache = getOrCreateActivityScopedCache(activity);
+    scopedCache.putPresenter(viewId, presenter);
+  }
+
+  /**
+   * Puts the presenter into the internal cache
+   *
+   * @param activity The parent activity
+   * @param viewId the view id (mosby internal)
+   * @param viewState the presenter
+   */
+  public static void putViewState(@NonNull Activity activity, @NonNull String viewId,
+      @NonNull Object viewState) {
+    if (activity == null) {
+      throw new NullPointerException("Activity is null");
+    }
+
+    ActivityScopedCache scopedCache = getOrCreateActivityScopedCache(activity);
+    scopedCache.putViewState(viewId, viewState);
+  }
+
+  /**
+   * Removes the Presenter (and ViewState) for the given View. Does nothing if no Presenter is
+   * stored internally with the given viewId
+   *
+   * @param activity The activity
+   * @param viewId The mosby internal view id
+   */
+  public static void remove(@NonNull Activity activity, @NonNull String viewId) {
+    if (activity == null) {
+      throw new NullPointerException("Activity is null");
+    }
+
+    ActivityScopedCache activityScope = getActivityScope(activity);
+    if (activityScope != null) {
+      activityScope.remove(viewId);
+    }
+  }
+}
+
+
+
+/*
+ * Copyright 2015 Hannes Dorfmann.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.hannesdorfmann.mosby3.mvp;
+
+import android.os.Bundle;
+
+import androidx.annotation.NonNull;
+import androidx.appcompat.app.AppCompatActivity;
+
+import com.hannesdorfmann.mosby3.mvp.delegate.ActivityMvpDelegate;
+import com.hannesdorfmann.mosby3.mvp.delegate.ActivityMvpDelegateImpl;
+
+/**
+ * An Activity that uses a {@link MvpPresenter} to implement a Model-View-Presenter
+ * architecture.
+ *
+ * @author Hannes Dorfmann
+ * @since 1.0.0
+ */
+public abstract class MvpActivity<V extends MvpView, P extends MvpPresenter<V>>
+    extends AppCompatActivity implements MvpView,
+    com.hannesdorfmann.mosby3.mvp.delegate.MvpDelegateCallback<V,P> {
+
+  protected ActivityMvpDelegate mvpDelegate;
+  protected P presenter;
+  protected boolean retainInstance;
+
+  @Override protected void onCreate(Bundle savedInstanceState) {
+    super.onCreate(savedInstanceState);
+    getMvpDelegate().onCreate(savedInstanceState);
+  }
+
+  @Override protected void onDestroy() {
+    super.onDestroy();
+    getMvpDelegate().onDestroy();
+  }
+
+  @Override protected void onSaveInstanceState(Bundle outState) {
+    super.onSaveInstanceState(outState);
+    getMvpDelegate().onSaveInstanceState(outState);
+  }
+
+  @Override protected void onPause() {
+    super.onPause();
+    getMvpDelegate().onPause();
+  }
+
+  @Override protected void onResume() {
+    super.onResume();
+    getMvpDelegate().onResume();
+  }
+
+  @Override protected void onStart() {
+    super.onStart();
+    getMvpDelegate().onStart();
+  }
+
+  @Override protected void onStop() {
+    super.onStop();
+    getMvpDelegate().onStop();
+  }
+
+  @Override protected void onRestart() {
+    super.onRestart();
+    getMvpDelegate().onRestart();
+  }
+
+  @Override public void onContentChanged() {
+    super.onContentChanged();
+    getMvpDelegate().onContentChanged();
+  }
+
+  @Override protected void onPostCreate(Bundle savedInstanceState) {
+    super.onPostCreate(savedInstanceState);
+    getMvpDelegate().onPostCreate(savedInstanceState);
+  }
+
+  /**
+   * Instantiate a presenter instance
+   *
+   * @return The {@link MvpPresenter} for this view
+   */
+  @NonNull
+  public abstract P createPresenter();
+
+  /**
+   * Get the mvp delegate. This is internally used for creating presenter, attaching and detaching
+   * view from presenter.
+   *
+   * <p><b>Please note that only one instance of mvp delegate should be used per Activity
+   * instance</b>.
+   * </p>
+   *
+   * <p>
+   * Only override this method if you really know what you are doing.
+   * </p>
+   *
+   * @return {@link ActivityMvpDelegateImpl}
+   */
+  @NonNull protected ActivityMvpDelegate<V, P> getMvpDelegate() {
+    if (mvpDelegate == null) {
+      mvpDelegate = new ActivityMvpDelegateImpl(this, this, true);
+    }
+
+    return mvpDelegate;
+  }
+
+  @NonNull @Override public P getPresenter() {
+    return presenter;
+  }
+
+  @Override public void setPresenter(@NonNull P presenter) {
+    this.presenter = presenter;
+  }
+
+  @NonNull @Override public V getMvpView() {
+    return (V) this;
+  }
+}
+/*
+ * Copyright 2015 Hannes Dorfmann.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.hannesdorfmann.mosby3.mvp;
+
+
+import androidx.annotation.NonNull;
+import androidx.annotation.UiThread;
+
+import java.lang.ref.WeakReference;
+
+/**
+ * A base implementation of a {@link MvpPresenter} that uses a <b>WeakReference</b> for referring
+ * to the attached view.
+ * <p>
+ * Use {@link #ifViewAttached(ViewAction)} to interact with the view. Since the view is passive,
+ * usually a Presenter should not get any data from View: so calls like view.getUserId() should not be done.
+ * Rather write a method in your Presenter that takes the user id as parameter like this:
+ * {@code
+ * void doSomething(int userId){
+ * // do something
+ * ...
+ * <p>
+ * ifViewAttached( view -> view.showSuccessful())
+ * }
+ * <p>
+ * }
+ * </p>
+ *
+ * @param <V> type of the {@link MvpView}
+ * @author Hannes Dorfmann
+ * @since 1.0.0
+ */
+public class MvpBasePresenter<V extends MvpView> implements MvpPresenter<V> {
+
+    /**
+     * An Action that is executed to interact with the view.
+     * Usually a Presenter should not get any data from View: so calls like view.getUserId() should not be done.
+     * Rather write a method in your Presenter that takes the user id as parameter like this:
+     * {@code
+     * void doSomething(int userId){
+     * // do something
+     * ...
+     * <p>
+     * ifViewAttached( view -> view.showSuccessful())
+     * }
+     *
+     * @param <V> The Type of the View
+     */
+    public interface ViewAction<V> {
+
+        /**
+         * This method will be invoked to run the action. Implement this method to interact with the view.
+         *
+         * @param view The reference to the view. Not null.
+         */
+        void run(@NonNull V view);
+    }
+
+    private WeakReference<V> viewRef;
+    private boolean presenterDestroyed = false;
+
+    @UiThread
+    @Override
+    public void attachView(V view) {
+        viewRef = new WeakReference<V>(view);
+        presenterDestroyed = false;
+    }
+
+    /**
+     * Gets the attached view. You should always call {@link #isViewAttached()} to check if the view
+     * is attached to avoid NullPointerExceptions.
+     *
+     * @return <code>null</code>, if view is not attached, otherwise the concrete view instance
+     * @deprecated Use {@link #ifViewAttached(ViewAction)}
+     */
+    @Deprecated
+    @UiThread
+    public V getView() {
+        return viewRef == null ? null : viewRef.get();
+    }
+
+    /**
+     * Checks if a view is attached to this presenter. You should always call this method before
+     * calling {@link #getView()} to get the view instance.
+     *
+     * @deprecated Use {@link #ifViewAttached(ViewAction)}
+     */
+    @Deprecated
+    @UiThread
+    public boolean isViewAttached() {
+        return viewRef != null && viewRef.get() != null;
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    @Deprecated
+    @UiThread
+    @Override
+    public void detachView(boolean retainInstance) {
+    }
+
+    /**
+     * Executes the passed Action only if the View is attached.
+     * If no View is attached, either an exception is thrown (if parameter exceptionIfViewNotAttached
+     * is true) or the action is just not executed (no exception thrown).
+     * Note that if no view is attached, this will not re-execute the given action if the View gets
+     * re-attached.
+     *
+     * @param exceptionIfViewNotAttached true, if an exception should be thrown if no view is
+     *                                   attached while trying to execute the action. false, if no exception should be thrown (the action
+     *                                   will not be executed since no view is attached)
+     * @param action                     The {@link ViewAction} that will be executed if a view is attached. This is
+     *                                   where you call view.isLoading etc. Use the view reference passed as parameter to {@link
+     *                                   ViewAction#run(Object)} and not deprecated method {@link #getView()}
+     */
+    protected final void ifViewAttached(boolean exceptionIfViewNotAttached, ViewAction<V> action) {
+        final V view = viewRef == null ? null : viewRef.get();
+        if (view != null) {
+            action.run(view);
+        } else if (exceptionIfViewNotAttached) {
+            throw new IllegalStateException(
+                    "No View attached to Presenter. Presenter destroyed = " + presenterDestroyed);
+        }
+    }
+
+    /**
+     * Calls {@link #ifViewAttached(boolean, ViewAction)} with false as first parameter (don't throw
+     * exception if view not attached).
+     *
+     * @see #ifViewAttached(boolean, ViewAction)
+     */
+    protected final void ifViewAttached(ViewAction<V> action) {
+        ifViewAttached(false, action);
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    public void detachView() {
+        detachView(true);
+        if (viewRef != null) {
+            viewRef.clear();
+            viewRef = null;
+        }
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    public void destroy() {
+        detachView(false);
+        presenterDestroyed = true;
+    }
+}
+package com.hannesdorfmann.mosby3.mvp;
+
+import android.app.Activity;
+import android.app.Dialog;
+import android.content.Context;
+import android.os.Bundle;
+import android.view.View;
+
+import androidx.annotation.NonNull;
+import androidx.annotation.Nullable;
+import androidx.fragment.app.DialogFragment;
+
+import com.hannesdorfmann.mosby3.mvp.delegate.FragmentMvpDelegate;
+import com.hannesdorfmann.mosby3.mvp.delegate.FragmentMvpDelegateImpl;
+import com.hannesdorfmann.mosby3.mvp.delegate.MvpDelegateCallback;
+
+/**
+ * A DialogFragment that uses an {@link MvpPresenter} to implement a Model-View-Presenter
+ * architecture
+ *
+ * @author Hannes Dorfmann
+ * @author Michał Seroczyński
+ * @since 3.1.1
+ */
+public abstract class MvpDialogFragment<V extends MvpView, P extends MvpPresenter<V>> extends DialogFragment
+    implements MvpDelegateCallback<V, P>, MvpView {
+
+  protected FragmentMvpDelegate<V, P> mvpDelegate;
+
+  /**
+   * The presenter for this view. Will be instantiated with {@link #createPresenter()}
+   */
+  protected P presenter;
+
+  /**
+   * Creates a new presenter instance, if needed. Will reuse the previous presenter instance if
+   * {@link #setRetainInstance(boolean)} is set to true. This method will be called from
+   * {@link #onViewCreated(View, Bundle)}
+   */
+  public abstract P createPresenter();
+
+  /**
+   * * Get the mvp delegate. This is internally used for creating presenter, attaching and
+   * detaching view from presenter.
+   *
+   * <p>
+   * <b>Please note that only one instance of mvp delegate should be used per fragment
+   * instance</b>.
+   * </p>
+   *
+   * <p>
+   * Only override this method if you really know what you are doing.
+   * </p>
+   *
+   * @return {@link FragmentMvpDelegateImpl}
+   */
+  @NonNull
+  protected FragmentMvpDelegate<V, P> getMvpDelegate() {
+    if (mvpDelegate == null) {
+      mvpDelegate = new FragmentMvpDelegateImpl<>(this, this, true, true);
+    }
+
+    return mvpDelegate;
+  }
+
+  @NonNull @Override public P getPresenter() {
+    return presenter;
+  }
+
+  @Override public void setPresenter(@NonNull P presenter) {
+    this.presenter = presenter;
+  }
+
+  @NonNull @Override public V getMvpView() {
+    return (V) this;
+  }
+
+  @Override
+  public void onViewCreated(View view, @Nullable Bundle savedInstanceState) {
+    super.onViewCreated(view, savedInstanceState);
+    getMvpDelegate().onViewCreated(view, savedInstanceState);
+  }
+
+  @Override public void onDestroyView() {
+    Dialog dialog = getDialog();
+    // Handles https://code.google.com/p/android/issues/detail?id=17423
+    if (dialog != null && getRetainInstance()) {
+      dialog.setDismissMessage(null);
+    }
+
+    super.onDestroyView();
+    getMvpDelegate().onDestroyView();
+  }
+
+  @Override public void onCreate(Bundle savedInstanceState) {
+    super.onCreate(savedInstanceState);
+    getMvpDelegate().onCreate(savedInstanceState);
+  }
+
+  @Override public void onDestroy() {
+    super.onDestroy();
+    getMvpDelegate().onDestroy();
+  }
+
+  @Override public void onPause() {
+    super.onPause();
+    getMvpDelegate().onPause();
+  }
+
+  @Override public void onResume() {
+    super.onResume();
+    getMvpDelegate().onResume();
+  }
+
+  @Override public void onStart() {
+    super.onStart();
+    getMvpDelegate().onStart();
+  }
+
+  @Override public void onStop() {
+    super.onStop();
+    getMvpDelegate().onStop();
+  }
+
+  @Override public void onActivityCreated(@Nullable Bundle savedInstanceState) {
+    super.onActivityCreated(savedInstanceState);
+    getMvpDelegate().onActivityCreated(savedInstanceState);
+  }
+
+  @Override public void onAttach(Activity activity) {
+    super.onAttach(activity);
+    getMvpDelegate().onAttach(activity);
+  }
+
+  @Override public void onAttach(Context context) {
+    super.onAttach(context);
+    getMvpDelegate().onAttach(context);
+  }
+
+  @Override public void onDetach() {
+    super.onDetach();
+    getMvpDelegate().onDetach();
+  }
+
+  @Override public void onSaveInstanceState(Bundle outState) {
+    super.onSaveInstanceState(outState);
+    getMvpDelegate().onSaveInstanceState(outState);
+  }
+
+}
 \ No newline at end of file
+/*
+ * Copyright 2015 Hannes Dorfmann.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.hannesdorfmann.mosby3.mvp;
+
+import android.app.Activity;
+import android.content.Context;
+import android.os.Bundle;
+import android.view.View;
+
+import androidx.annotation.NonNull;
+import androidx.annotation.Nullable;
+import androidx.fragment.app.Fragment;
+
+import com.hannesdorfmann.mosby3.mvp.delegate.FragmentMvpDelegate;
+import com.hannesdorfmann.mosby3.mvp.delegate.FragmentMvpDelegateImpl;
+import com.hannesdorfmann.mosby3.mvp.delegate.MvpDelegateCallback;
+
+/**
+ * A Fragment that uses a {@link MvpPresenter} to implement a Model-View-Presenter architecture.
+ *
+ * @author Hannes Dorfmann
+ * @since 1.0.0
+ */
+public abstract class MvpFragment<V extends MvpView, P extends MvpPresenter<V>> extends Fragment
+    implements MvpDelegateCallback<V, P>, MvpView {
+
+  protected FragmentMvpDelegate<V, P> mvpDelegate;
+
+  /**
+   * The presenter for this view. Will be instantiated with {@link #createPresenter()}
+   */
+  protected P presenter;
+
+  /**
+   * Creates a new presenter instance, if needed. Will reuse the previous presenter instance if
+   * {@link #setRetainInstance(boolean)} is set to true. This method will be called from
+   * {@link #onViewCreated(View, Bundle)}
+   */
+  public abstract P createPresenter();
+
+  /**
+   * Gets the mvp delegate. This is internally used for creating presenter, attaching and
+   * detaching view from presenter.
+   *
+   * <p>
+   * <b>Please note that only one instance of mvp delegate should be used per fragment instance</b>.
+   * </p>
+   *
+   * <p>
+   * Only override this method if you really know what you are doing.
+   * </p>
+   *
+   * @return {@link FragmentMvpDelegateImpl}
+   */
+  @NonNull
+  protected FragmentMvpDelegate<V, P> getMvpDelegate() {
+    if (mvpDelegate == null) {
+      mvpDelegate = new FragmentMvpDelegateImpl<>(this, this, true, true);
+    }
+
+    return mvpDelegate;
+  }
+
+  @NonNull @Override public P getPresenter() {
+    return presenter;
+  }
+
+  @Override public void setPresenter(@NonNull P presenter) {
+    this.presenter = presenter;
+  }
+
+  @NonNull @Override public V getMvpView() {
+    return (V) this;
+  }
+
+  @Override public void onViewCreated(View view, @Nullable Bundle savedInstanceState) {
+    super.onViewCreated(view, savedInstanceState);
+    getMvpDelegate().onViewCreated(view, savedInstanceState);
+  }
+
+  @Override public void onDestroyView() {
+    super.onDestroyView();
+    getMvpDelegate().onDestroyView();
+  }
+
+  @Override public void onCreate(Bundle savedInstanceState) {
+    super.onCreate(savedInstanceState);
+    getMvpDelegate().onCreate(savedInstanceState);
+  }
+
+  @Override public void onDestroy() {
+    super.onDestroy();
+    getMvpDelegate().onDestroy();
+  }
+
+  @Override public void onPause() {
+    super.onPause();
+    getMvpDelegate().onPause();
+  }
+
+  @Override public void onResume() {
+    super.onResume();
+    getMvpDelegate().onResume();
+  }
+
+  @Override public void onStart() {
+    super.onStart();
+    getMvpDelegate().onStart();
+  }
+
+  @Override public void onStop() {
+    super.onStop();
+    getMvpDelegate().onStop();
+  }
+
+  @Override public void onActivityCreated(@Nullable Bundle savedInstanceState) {
+    super.onActivityCreated(savedInstanceState);
+    getMvpDelegate().onActivityCreated(savedInstanceState);
+  }
+
+  @Deprecated @Override public void onAttach(Activity activity) {
+    super.onAttach(activity);
+    getMvpDelegate().onAttach(activity);
+  }
+
+  @Override public void onAttach(Context context) {
+    super.onAttach(context);
+    getMvpDelegate().onAttach(context);
+  }
+
+  @Override public void onDetach() {
+    super.onDetach();
+    getMvpDelegate().onDetach();
+  }
+
+  @Override public void onSaveInstanceState(Bundle outState) {
+    super.onSaveInstanceState(outState);
+    getMvpDelegate().onSaveInstanceState(outState);
+  }
+}
+
+/*
+ * Copyright 2015 Hannes Dorfmann.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.hannesdorfmann.mosby3.mvp;
+
+
+import androidx.annotation.NonNull;
+import androidx.annotation.UiThread;
+
+/**
+ * The base interface for each mvp presenter.
+ *
+ * <p>
+ * Mosby assumes that all interaction (i.e. updating the View) between Presenter and View is
+ * executed on Android's main UI thread.
+ * </p>
+ *
+ * @author Hannes Dorfmann
+ * @since 1.0.0
+ */
+public interface MvpPresenter<V extends MvpView> {
+
+  /**
+   * Set or attach the view to this presenter
+   */
+  @UiThread
+  void attachView(@NonNull V view);
+
+  /**
+   * Will be called if the view has been destroyed. Typically this method will be invoked from
+   * <code>Activity.detachView()</code> or <code>Fragment.onDestroyView()</code>
+   *
+   * @deprecated This method has been split into 2 methods: {@link #detachView()} and {@link #destroy()}
+    */
+  @UiThread
+  @Deprecated
+  void detachView(boolean retainInstance);
+
+  /**
+   * Will be called if the view has been detached from the Presenter.
+   * Usually this happens on screen orientation changes or view (like fragment) has been put on the backstack.
+   */
+  @UiThread
+  void detachView();
+
+  /**
+   * Will be called if the presenter is no longer needed because the View has been destroyed permanently.
+   * This is where you do clean up stuff.
+   */
+  @UiThread
+  void destroy();
+}
+/*
+ * Copyright 2015 Hannes Dorfmann.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.hannesdorfmann.mosby3.mvp;
+
+/**
+ * The root view interface for every mvp view
+ *
+ * @author Hannes Dorfmann
+ * @since 1.0.0
+ */
+public interface MvpView {
+}
+/*
+ * Copyright 2015 Hannes Dorfmann.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.hannesdorfmann.mosby3.mvp.delegate;
+
+import android.app.Activity;
+import android.os.Bundle;
+import com.hannesdorfmann.mosby3.mvp.MvpPresenter;
+import com.hannesdorfmann.mosby3.mvp.MvpView;
+
+/**
+ * A delegate for Activities to attach them to Mosby mvp.
+ *
+ * <p>
+ * The following methods must be invoked from the corresponding Activities lifecycle methods:
+ * <ul>
+ * <li>{@link #onCreate(Bundle)}</li>
+ * <li>{@link #onDestroy()}</li>
+ * <li>{@link #onPause()} </li>
+ * <li>{@link #onResume()} </li>
+ * <li>{@link #onStart()} </li>
+ * <li>{@link #onStop()} </li>
+ * <li>{@link #onRestart()} </li>
+ * <li>{@link #onContentChanged()} </li>
+ * <li>{@link #onSaveInstanceState(Bundle)} </li>
+ * <li>{@link #onPostCreate(Bundle)} </li>
+ * <li></li>
+ * </ul>
+ * </p>
+ *
+ * @param <V> The type of {@link MvpView}
+ * @param <P> The type of {@link MvpPresenter}
+ * @author Hannes Dorfmann
+ * @since 1.1.0
+ */
+public interface ActivityMvpDelegate<V extends MvpView, P extends MvpPresenter<V>> {
+
+  /**
+   * This method must be called from {@link Activity#onCreate(Bundle)}.
+   * This method internally creates the presenter and attaches the view to it.
+   */
+  void onCreate(Bundle bundle);
+
+  /**
+   * This method must be called from {@link Activity#onDestroy()}}.
+   * This method internally detaches the view from presenter
+   */
+  void onDestroy();
+
+  /**
+   * This method must be called from {@link Activity#onPause()}
+   */
+  void onPause();
+
+  /**
+   * This method must be called from {@link Activity#onResume()}
+   */
+  void onResume();
+
+  /**
+   * This method must be called from {@link Activity#onStart()}
+   */
+  void onStart();
+
+  /**
+   * This method must be called from {@link Activity#onStop()}
+   */
+  void onStop();
+
+  /**
+   * This method must be called from {@link Activity#onRestart()}
+   */
+  void onRestart();
+
+  /**
+   * This method must be called from {@link Activity#onContentChanged()}
+   */
+  void onContentChanged();
+
+  /**
+   * This method must be called from {@link Activity#onSaveInstanceState(Bundle)}
+   */
+  void onSaveInstanceState(Bundle outState);
+
+  /**
+   * This method must be called from {@link Activity#onPostCreate(Bundle)}
+   */
+  void onPostCreate(Bundle savedInstanceState);
+
+}
+/*
+ * Copyright 2015 Hannes Dorfmann.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.hannesdorfmann.mosby3.mvp.delegate;
+
+import android.app.Activity;
+import android.os.Bundle;
+import android.util.Log;
+
+import androidx.annotation.NonNull;
+
+import com.hannesdorfmann.mosby3.PresenterManager;
+import com.hannesdorfmann.mosby3.mvp.MvpPresenter;
+import com.hannesdorfmann.mosby3.mvp.MvpView;
+import java.util.UUID;
+
+/**
+ * The concrete implementation of {@link}
+ *
+ * @param <V> The type of {@link MvpView}
+ * @param <P> The type of {@link MvpPresenter}
+ * @author Hannes Dorfmann
+ * @see ActivityMvpDelegate
+ * @since 1.1.0
+ */
+public class ActivityMvpDelegateImpl<V extends MvpView, P extends MvpPresenter<V>>
+    implements ActivityMvpDelegate {
+
+  protected static final String KEY_MOSBY_VIEW_ID = "com.hannesdorfmann.mosby3.activity.mvp.id";
+
+  public static boolean DEBUG = false;
+  private static final String DEBUG_TAG = "ActivityMvpDelegateImpl";
+
+  private MvpDelegateCallback<V, P> delegateCallback;
+  protected boolean keepPresenterInstance;
+  protected Activity activity;
+  protected String mosbyViewId = null;
+
+  /**
+   * @param activity The Activity
+   * @param delegateCallback The callback
+   * @param keepPresenterInstance true, if the presenter instance should be kept across screen
+   * orientation changes. Otherwise false.
+   */
+  public ActivityMvpDelegateImpl(@NonNull Activity activity,
+      @NonNull MvpDelegateCallback<V, P> delegateCallback, boolean keepPresenterInstance) {
+
+    if (activity == null) {
+      throw new NullPointerException("Activity is null!");
+    }
+
+    if (delegateCallback == null) {
+      throw new NullPointerException("MvpDelegateCallback is null!");
+    }
+    this.delegateCallback = delegateCallback;
+    this.activity = activity;
+    this.keepPresenterInstance = keepPresenterInstance;
+  }
+
+  /**
+   * Determines whether or not a Presenter Instance should be kept
+   *
+   * @param keepPresenterInstance true, if the delegate has enabled keep
+   */
+  static boolean retainPresenterInstance(boolean keepPresenterInstance, Activity activity) {
+    return keepPresenterInstance && (activity.isChangingConfigurations()
+        || !activity.isFinishing());
+  }
+
+  /**
+   * Generates the unique (mosby internal) view id and calls {@link
+   * MvpDelegateCallback#createPresenter()}
+   * to create a new presenter instance
+   *
+   * @return The new created presenter instance
+   */
+  private P createViewIdAndCreatePresenter() {
+
+    P presenter = delegateCallback.createPresenter();
+    if (presenter == null) {
+      throw new NullPointerException(
+          "Presenter returned from createPresenter() is null. Activity is " + activity);
+    }
+    if (keepPresenterInstance) {
+      mosbyViewId = UUID.randomUUID().toString();
+      PresenterManager.putPresenter(activity, mosbyViewId, presenter);
+    }
+    return presenter;
+  }
+
+  @Override public void onCreate(Bundle bundle) {
+
+    P presenter = null;
+
+    if (bundle != null && keepPresenterInstance) {
+
+      mosbyViewId = bundle.getString(KEY_MOSBY_VIEW_ID);
+
+      if (DEBUG) {
+        Log.d(DEBUG_TAG,
+            "MosbyView ID = " + mosbyViewId + " for MvpView: " + delegateCallback.getMvpView());
+      }
+
+      if (mosbyViewId != null
+          && (presenter = PresenterManager.getPresenter(activity, mosbyViewId)) != null) {
+        //
+        // Presenter restored from cache
+        //
+        if (DEBUG) {
+          Log.d(DEBUG_TAG,
+              "Reused presenter " + presenter + " for view " + delegateCallback.getMvpView());
+        }
+      } else {
+        //
+        // No presenter found in cache, most likely caused by process death
+        //
+        presenter = createViewIdAndCreatePresenter();
+        if (DEBUG) {
+          Log.d(DEBUG_TAG, "No presenter found although view Id was here: "
+              + mosbyViewId
+              + ". Most likely this was caused by a process death. New Presenter created"
+              + presenter
+              + " for view "
+              + getMvpView());
+        }
+      }
+    } else {
+      //
+      // Activity starting first time, so create a new presenter
+      //
+      presenter = createViewIdAndCreatePresenter();
+      if (DEBUG) {
+        Log.d(DEBUG_TAG, "New presenter " + presenter + " for view " + getMvpView());
+      }
+    }
+
+    if (presenter == null) {
+      throw new IllegalStateException(
+          "Oops, Presenter is null. This seems to be a Mosby internal bug. Please report this issue here: https://github.com/sockeqwe/mosby/issues");
+    }
+
+    delegateCallback.setPresenter(presenter);
+    getPresenter().attachView(getMvpView());
+
+    if (DEBUG) {
+      Log.d(DEBUG_TAG, "View" + getMvpView() + " attached to Presenter " + presenter);
+    }
+  }
+
+  private P getPresenter() {
+    P presenter = delegateCallback.getPresenter();
+    if (presenter == null) {
+      throw new NullPointerException("Presenter returned from getPresenter() is null");
+    }
+    return presenter;
+  }
+
+  private V getMvpView() {
+    V view = delegateCallback.getMvpView();
+    if (view == null) {
+      throw new NullPointerException("View returned from getMvpView() is null");
+    }
+    return view;
+  }
+
+  @Override public void onDestroy() {
+    boolean retainPresenterInstance = retainPresenterInstance(keepPresenterInstance, activity);
+    getPresenter().detachView();
+    if (!retainPresenterInstance){
+      getPresenter().destroy();
+    }
+    if (!retainPresenterInstance && mosbyViewId != null) {
+      PresenterManager.remove(activity, mosbyViewId);
+    }
+
+    if (DEBUG) {
+      if (retainPresenterInstance) {
+        Log.d(DEBUG_TAG, "View"
+            + getMvpView()
+            + " destroyed temporarily. View detached from presenter "
+            + getPresenter());
+      } else {
+        Log.d(DEBUG_TAG, "View"
+            + getMvpView()
+            + " destroyed permanently. View detached permanently from presenter "
+            + getPresenter());
+      }
+    }
+  }
+
+  @Override public void onPause() {
+
+  }
+
+  @Override public void onResume() {
+
+  }
+
+  @Override public void onStart() {
+
+  }
+
+  @Override public void onStop() {
+
+  }
+
+  @Override public void onRestart() {
+
+  }
+
+  @Override public void onContentChanged() {
+
+  }
+
+  @Override public void onSaveInstanceState(Bundle outState) {
+    if (keepPresenterInstance && outState != null) {
+      outState.putString(KEY_MOSBY_VIEW_ID, mosbyViewId);
+      if (DEBUG) {
+        Log.d(DEBUG_TAG,
+            "Saving MosbyViewId into Bundle. ViewId: " + mosbyViewId + " for view " + getMvpView());
+      }
+    }
+  }
+
+  @Override public void onPostCreate(Bundle savedInstanceState) {
+  }
+}
+/*
+ * Copyright 2016 Hannes Dorfmann.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package com.hannesdorfmann.mosby3.mvp.delegate;
+
+import androidx.fragment.app.Fragment;
+
+import java.io.PrintWriter;
+import java.io.StringWriter;
+
+/**
+ * With this utility class one can access the fragment backstack
+ *
+ * @author Hannes Dorfmann
+ */
+public class BackstackAccessor {
+
+  private BackstackAccessor() {
+    throw new IllegalStateException("Not instantiatable");
+  }
+
+  /**
+   * Checks whether or not a given fragment is on the backstack of the fragment manager (could also
+   * be on top of the backstack and hence visible)
+   *
+   * @param fragment The fragment you want to check if its on the back stack
+   * @return true, if the given Fragment is on the back stack, otherwise false (not on the back
+   * stack)
+   */
+  //todo
+//  public static boolean isFragmentOnBackStack(Fragment fragment) {
+//      try {
+////          return fragment.isInBackStack();
+//          return true;
+//      } catch (IllegalAccessError e) {
+//          return isInBackStackAndroidX(fragment);
+//      }
+//  }
+
+    /**
+     * As of version 1.0 of AndroidX - fragment.isInBackStack() is package private which leads to
+     * an IllegalAccessError being thrown when trying to use it.
+     * This method is a temporary workaround until the issue is resolved in AndroidX.
+     */
+    public static boolean isInBackStackAndroidX(final Fragment fragment) {
+        final StringWriter writer = new StringWriter();
+        fragment.dump("", null, new PrintWriter(writer), null);
+        final String dump = writer.toString();
+        return !dump.contains("mBackStackNesting=0");
+    }
+/*
+  public static boolean isFragmentOnBackStack(Fragment fragment) {
+
+    FragmentManager fragmentManager = fragment.getFragmentManager();
+    int backStackSize = fragmentManager.getBackStackEntryCount();
+    for (int i = 0; i < backStackSize; i++) {
+      BackStackRecord stackEntry = (BackStackRecord) fragmentManager.getBackStackEntryAt(i);
+      int opsCount = stackEntry.mOps == null ? 0 : stackEntry.mOps.size();
+      if (opsCount > 0) {
+        BackStackRecord.Op op = stackEntry.mOps.get(opsCount-1);
+        if (op.fragment == fragment) {
+          return true;
+        }
+      }
+    }
+
+    return false;
+  }
+*/
+
+/*
+  private static boolean findNext(@NonNull Fragment toFind, @Nullable BackStackRecord.Op next) {
+    if (next == null) {
+      return false;
+    }
+
+    if (toFind == next.fragment) {
+      return true;
+    } else {
+      return findNext(toFind, next.next);
+    }
+  }
+
+  private static boolean findPrevious(@NonNull Fragment toFind,
+      @Nullable BackStackRecord.Op previous) {
+    if (previous == null) {
+      return false;
+    }
+
+    if (toFind == previous.fragment) {
+      return true;
+    } else {
+      return findPrevious(toFind, previous.prev);
+    }
+  }
+  */
+}
+/*
+ * Copyright 2015 Hannes Dorfmann.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.hannesdorfmann.mosby3.mvp.delegate;
+
+import android.app.Activity;
+import android.content.Context;
+import android.os.Bundle;
+import android.view.View;
+
+import androidx.annotation.Nullable;
+
+import com.hannesdorfmann.mosby3.mvp.MvpPresenter;
+import com.hannesdorfmann.mosby3.mvp.MvpView;
+
+/**
+ * A delegate for Fragments to attach them to mosby mvp.
+ * <p>
+ * The following methods must be invoked from the corresponding Fragments lifecycle methods:
+ *
+ * <ul>
+ * <li>{@link #onCreate(Bundle)}</li>
+ * <li>{@link #onDestroy()}</li>
+ * <li>{@link #onPause()} </li>
+ * <li>{@link #onResume()} </li>
+ * <li>{@link #onStart()} </li>
+ * <li>{@link #onStop()} </li>
+ * <li>{@link #onViewCreated(View, Bundle)} </li>
+ * <li>{@link #onActivityCreated(Bundle)} </li>
+ * <li>{@link #onSaveInstanceState(Bundle)} </li>
+ * <li>{@link #onAttach(Activity)} </li>
+ * <li>{@link #onAttach(Context)} </li>
+ * <li>{@link #onDetach()}</li>
+ * <li></li>
+ * </ul>
+ * </p>
+ *
+ * @param <V> The type of {@link MvpView}
+ * @param <P> The type of {@link MvpPresenter}
+ * @author Hannes Dorfmann
+ * @since 1.1.0
+ */
+public interface FragmentMvpDelegate<V extends MvpView, P extends MvpPresenter<V>> {
+
+  /**
+   * Must be called from {@link Fragment#onCreate(Bundle)}
+   *
+   * @param saved The bundle
+   */
+  void onCreate(Bundle saved);
+
+  /**
+   * Must be called from {@link Fragment#onDestroy()}
+   */
+  void onDestroy();
+
+  /**
+   * Must be called from {@link Fragment#onViewCreated(View, Bundle)}
+   *
+   * @param view The inflated view
+   * @param savedInstanceState the bundle with the viewstate
+   */
+  void onViewCreated(View view, @Nullable Bundle savedInstanceState);
+
+  /**
+   * Must be called from {@link Fragment#onDestroyView()}
+   */
+  void onDestroyView();
+
+  /**
+   * Must be called from {@link Fragment#onPause()}
+   */
+  void onPause();
+
+  /**
+   * Must be called from {@link Fragment#onResume()}
+   */
+  void onResume();
+
+  /**
+   * Must be called from {@link Fragment#onStart()}
+   */
+  void onStart();
+
+  /**
+   * Must be called from {@link Fragment#onStop()}
+   */
+  void onStop();
+
+  /**
+   * Must be called from {@link Fragment#onActivityCreated(Bundle)}
+   *
+   * @param savedInstanceState The saved bundle
+   */
+  void onActivityCreated(Bundle savedInstanceState);
+
+  /**
+   * Must be called from {@link Fragment#onAttach(Activity)}
+   *
+   * @param activity The activity the fragment is attached to
+   */
+  @Deprecated
+  void onAttach(Activity activity);
+
+  /**
+   * Must be called from {@link Fragment#onAttach(Context)}
+   *
+   * @param context The context the fragment is attached to
+   */
+  void onAttach(Context context);
+
+  /**
+   * Must be called from {@link Fragment#onDetach()}
+   */
+  void onDetach();
+
+  /**
+   * Must be called from {@link Fragment#onSaveInstanceState(Bundle)}
+   */
+  void onSaveInstanceState(Bundle outState);
+}
+/*
+ * Copyright 2015 Hannes Dorfmann.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.hannesdorfmann.mosby3.mvp.delegate;
+
+import android.app.Activity;
+import android.content.Context;
+import android.os.Bundle;
+import android.util.Log;
+import android.view.View;
+
+import androidx.annotation.NonNull;
+import androidx.annotation.Nullable;
+import androidx.fragment.app.Fragment;
+
+import com.hannesdorfmann.mosby3.PresenterManager;
+import com.hannesdorfmann.mosby3.mvp.MvpPresenter;
+import com.hannesdorfmann.mosby3.mvp.MvpView;
+
+import java.util.UUID;
+
+/**
+ * The default implementation of {@link FragmentMvpDelegate}
+ * Presenter is available (has view that is attached) in {@link #onViewCreated(View, Bundle)} (after
+ * super.onViewCreated() is called). View will be detached in {@link #onDestroyView()} from presenter,
+ * and eventually presenter will be destroyed in {@link #onDestroy()}.
+ *
+ * @param <V> The type of {@link MvpView}
+ * @param <P> The type of {@link MvpPresenter}
+ * @author Hannes Dorfmann
+ * @see FragmentMvpDelegate
+ * @since 1.1.0
+ */
+public class FragmentMvpDelegateImpl<V extends MvpView, P extends MvpPresenter<V>>
+        implements FragmentMvpDelegate<V, P> {
+
+    protected static final String KEY_MOSBY_VIEW_ID = "com.hannesdorfmann.mosby3.fragment.mvp.id";
+
+    public static boolean DEBUG = false;
+    private static final String DEBUG_TAG = "FragmentMvpVSDelegate";
+
+    private MvpDelegateCallback<V, P> delegateCallback;
+    protected Fragment fragment;
+    protected final boolean keepPresenterInstanceDuringScreenOrientationChanges;
+    protected final boolean keepPresenterOnBackstack;
+    private boolean onViewCreatedCalled = false;
+    protected String mosbyViewId;
+
+    /**
+     * @param fragment                                   The Fragment
+     * @param delegateCallback                           the DelegateCallback
+     * @param keepPresenterDuringScreenOrientationChange true, if the presenter should be kept during
+     *                                                   screen orientation
+     *                                                   changes. Otherwise, false
+     * @param keepPresenterOnBackstack                   true, if the presenter should be kept when the fragment is
+     *                                                   destroyed because it is put on the backstack, Otherwise false
+     */
+    public FragmentMvpDelegateImpl(@NonNull Fragment fragment,
+                                   @NonNull MvpDelegateCallback<V, P> delegateCallback,
+                                   boolean keepPresenterDuringScreenOrientationChange, boolean keepPresenterOnBackstack) {
+        if (delegateCallback == null) {
+            throw new NullPointerException("MvpDelegateCallback is null!");
+        }
+
+        if (fragment == null) {
+            throw new NullPointerException("Fragment is null!");
+        }
+
+        if (!keepPresenterDuringScreenOrientationChange && keepPresenterOnBackstack) {
+            throw new IllegalArgumentException("It is not possible to keep the presenter on backstack, "
+                    + "but NOT keep presenter through screen orientation changes. Keep presenter on backstack also "
+                    + "requires keep presenter through screen orientation changes to be enabled");
+        }
+
+        this.fragment = fragment;
+        this.delegateCallback = delegateCallback;
+        this.keepPresenterInstanceDuringScreenOrientationChanges =
+                keepPresenterDuringScreenOrientationChange;
+        this.keepPresenterOnBackstack = keepPresenterOnBackstack;
+    }
+
+    /**
+     * Generates the unique (mosby internal) view id and calls {@link
+     * MvpDelegateCallback#createPresenter()}
+     * to create a new presenter instance
+     *
+     * @return The new created presenter instance
+     */
+    private P createViewIdAndCreatePresenter() {
+
+        P presenter = delegateCallback.createPresenter();
+        if (presenter == null) {
+            throw new NullPointerException(
+                    "Presenter returned from createPresenter() is null. Activity is " + getActivity());
+        }
+        if (keepPresenterInstanceDuringScreenOrientationChanges) {
+            mosbyViewId = UUID.randomUUID().toString();
+            PresenterManager.putPresenter(getActivity(), mosbyViewId, presenter);
+        }
+        return presenter;
+    }
+
+    @Override
+    public void onViewCreated(View view, @Nullable Bundle bundle) {
+
+        P presenter = getPresenter();
+        presenter.attachView(getMvpView());
+
+        if (DEBUG) {
+            Log.d(DEBUG_TAG, "View" + getMvpView() + " attached to Presenter " + presenter);
+        }
+
+        onViewCreatedCalled = true;
+    }
+
+    @NonNull
+    private Activity getActivity() {
+        Activity activity = fragment.getActivity();
+        if (activity == null) {
+            throw new NullPointerException(
+                    "Activity returned by Fragment.getActivity() is null. Fragment is " + fragment);
+        }
+
+        return activity;
+    }
+
+    private P getPresenter() {
+        P presenter = delegateCallback.getPresenter();
+        if (presenter == null) {
+            throw new NullPointerException("Presenter returned from getPresenter() is null");
+        }
+        return presenter;
+    }
+
+    private V getMvpView() {
+        V view = delegateCallback.getMvpView();
+        if (view == null) {
+            throw new NullPointerException("View returned from getMvpView() is null");
+        }
+        return view;
+    }
+
+    static boolean retainPresenterInstance(Activity activity, Fragment fragment,
+                                           boolean keepPresenterInstanceDuringScreenOrientationChanges,
+                                           boolean keepPresenterOnBackstack) {
+
+        if (activity.isChangingConfigurations()) {
+            return keepPresenterInstanceDuringScreenOrientationChanges;
+        }
+
+        if (activity.isFinishing()) {
+            return false;
+        }
+//todo 修改androidx
+        if (keepPresenterOnBackstack && BackstackAccessor.isInBackStackAndroidX(fragment)) {
+            return true;
+        }
+
+        return !fragment.isRemoving();
+    }
+
+    @Override
+    public void onDestroyView() {
+
+        onViewCreatedCalled = false;
+
+        getPresenter().detachView();
+
+        if (DEBUG) {
+            Log.d(DEBUG_TAG, "detached MvpView from Presenter. MvpView "
+                    + delegateCallback.getMvpView()
+                    + "   Presenter: "
+                    + getPresenter());
+        }
+    }
+
+    @Override
+    public void onPause() {
+
+    }
+
+    @Override
+    public void onResume() {
+
+    }
+
+    @Override
+    public void onStart() {
+
+        if (!onViewCreatedCalled) {
+            throw new IllegalStateException("It seems that you are using "
+                    + delegateCallback.getClass().getCanonicalName()
+                    + " as headless (UI less) fragment (because onViewCreated() has not been called or maybe delegation misses that part). Having a Presenter without a View (UI) doesn't make sense. Simply use an usual fragment instead of an MvpFragment if you want to use a UI less Fragment");
+        }
+    }
+
+    @Override
+    public void onStop() {
+
+    }
+
+    @Override
+    public void onActivityCreated(Bundle savedInstanceState) {
+
+    }
+
+    @Override
+    public void onAttach(Activity activity) {
+
+    }
+
+    @Override
+    public void onAttach(Context context) {
+
+    }
+
+    @Override
+    public void onDetach() {
+
+    }
+
+    @Override
+    public void onSaveInstanceState(Bundle outState) {
+        if ((keepPresenterInstanceDuringScreenOrientationChanges || keepPresenterOnBackstack)
+                && outState != null) {
+            outState.putString(KEY_MOSBY_VIEW_ID, mosbyViewId);
+
+            if (DEBUG) {
+                Log.d(DEBUG_TAG, "Saving MosbyViewId into Bundle. ViewId: " + mosbyViewId);
+            }
+        }
+    }
+
+    @Override
+    public void onCreate(Bundle bundle) {
+
+        P presenter = null;
+
+        if (bundle != null && keepPresenterInstanceDuringScreenOrientationChanges) {
+
+            mosbyViewId = bundle.getString(KEY_MOSBY_VIEW_ID);
+
+            if (DEBUG) {
+                Log.d(DEBUG_TAG,
+                        "MosbyView ID = " + mosbyViewId + " for MvpView: " + delegateCallback.getMvpView());
+            }
+
+            if (mosbyViewId != null
+                    && (presenter = PresenterManager.getPresenter(getActivity(), mosbyViewId)) != null) {
+                //
+                // Presenter restored from cache
+                //
+                if (DEBUG) {
+                    Log.d(DEBUG_TAG,
+                            "Reused presenter " + presenter + " for view " + delegateCallback.getMvpView());
+                }
+            } else {
+                //
+                // No presenter found in cache, most likely caused by process death
+                //
+                presenter = createViewIdAndCreatePresenter();
+                if (DEBUG) {
+                    Log.d(DEBUG_TAG, "No presenter found although view Id was here: "
+                            + mosbyViewId
+                            + ". Most likely this was caused by a process death. New Presenter created"
+                            + presenter
+                            + " for view "
+                            + getMvpView());
+                }
+            }
+        } else {
+            //
+            // Activity starting first time, so create a new presenter
+            //
+            presenter = createViewIdAndCreatePresenter();
+            if (DEBUG) {
+                Log.d(DEBUG_TAG, "New presenter " + presenter + " for view " + getMvpView());
+            }
+        }
+
+        if (presenter == null) {
+            throw new IllegalStateException(
+                    "Oops, Presenter is null. This seems to be a Mosby internal bug. Please report this issue here: https://github.com/sockeqwe/mosby/issues");
+        }
+
+        delegateCallback.setPresenter(presenter);
+    }
+
+    @Override
+    public void onDestroy() {
+
+        Activity activity = getActivity();
+        boolean retainPresenterInstance = retainPresenterInstance(activity, fragment,
+                keepPresenterInstanceDuringScreenOrientationChanges, keepPresenterOnBackstack);
+
+        P presenter = getPresenter();
+        if (!retainPresenterInstance) {
+            presenter.destroy();
+            if (DEBUG) {
+                Log.d(DEBUG_TAG, "Presenter destroyed. MvpView "
+                        + delegateCallback.getMvpView()
+                        + "   Presenter: "
+                        + presenter);
+            }
+        }
+
+        if (!retainPresenterInstance && mosbyViewId != null) {
+            // mosbyViewId is null if keepPresenterInstanceDuringScreenOrientationChanges  == false
+            PresenterManager.remove(activity, mosbyViewId);
+        }
+    }
+}
+/*
+ * Copyright 2015 Hannes Dorfmann.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.hannesdorfmann.mosby3.mvp.delegate;
+
+
+import androidx.annotation.NonNull;
+
+import com.hannesdorfmann.mosby3.mvp.MvpPresenter;
+import com.hannesdorfmann.mosby3.mvp.MvpView;
+
+/**
+ * The MvpDelegate callback that will be called from {@link
+ * FragmentMvpDelegate} or {@link ViewGroupMvpDelegate}. This interface must be implemented by all
+ * Fragment or android.view.View that you want to support Mosby mvp.
+ *
+ * @param <V> The type of {@link MvpView}
+ * @param <P> The type of {@link MvpPresenter}
+ * @author Hannes Dorfmann
+ * @since 1.1.0
+ */
+public interface MvpDelegateCallback<V extends MvpView, P extends MvpPresenter<V>> {
+
+  /**
+   * Creates the presenter instance
+   *
+   * @return the created presenter instance
+   */
+  @NonNull
+  P createPresenter();
+
+  /**
+   * Gets the presenter. If null is returned, then a internally a new presenter instance gets
+   * created by calling {@link #createPresenter()}
+   *
+   * @return the presenter instance. can be null.
+   */
+  P getPresenter();
+
+  /**
+   * Sets the presenter instance
+   *
+   * @param presenter The presenter instance
+   */
+  void setPresenter(P presenter);
+
+  /**
+   * Gets the MvpView for the presenter
+   *
+   * @return The view associated with the presenter
+   */
+  V getMvpView();
+}
+
+/*
+ * Copyright 2015 Hannes Dorfmann.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.hannesdorfmann.mosby3.mvp.delegate;
+
+import android.content.Context;
+import android.os.Parcelable;
+import com.hannesdorfmann.mosby3.mvp.MvpPresenter;
+import com.hannesdorfmann.mosby3.mvp.MvpView;
+
+/**
+ * An enhanced version of {@link MvpDelegateCallback} that adds support for
+ * android.view.View like FrameLayout etc.
+ *
+ * @author Hannes Dorfmann
+ * @since 3.0
+ */
+public interface ViewGroupDelegateCallback<V extends MvpView, P extends MvpPresenter<V>>
+    extends MvpDelegateCallback<V, P> {
+
+  /**
+   * This method must call super.onSaveInstanceState() within any view
+   */
+  Parcelable superOnSaveInstanceState();
+
+  /**
+   * This method must call super.onRestoreInstanceState(state)
+   *
+   * @param state The parcelable containing the state
+   */
+  void superOnRestoreInstanceState(Parcelable state);
+
+  /**
+   * Get the context
+   *
+   * @return Get the context
+   * @since 3.0
+   */
+  Context getContext();
+}
+/*
+ * Copyright 2015 Hannes Dorfmann.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.hannesdorfmann.mosby3.mvp.delegate;
+
+import android.os.Parcelable;
+import android.view.View;
+import android.widget.FrameLayout;
+import com.hannesdorfmann.mosby3.mvp.MvpPresenter;
+import com.hannesdorfmann.mosby3.mvp.MvpView;
+
+/**
+ * The mvp delegate used for everything that derives from {@link View} like {@link FrameLayout}
+ * etc.
+ *
+ * <p>
+ * The following methods must be called from the corresponding View lifecycle method:
+ * <ul>
+ * <li>{@link #onAttachedToWindow()}</li>
+ * <li>{@link #onDetachedFromWindow()}</li>
+ * </ul>
+ * </p>
+ *
+ * @author Hannes Dorfmann
+ * @since 1.1.0
+ */
+public interface ViewGroupMvpDelegate<V extends MvpView, P extends MvpPresenter<V>> {
+
+  /**
+   * Must be called from {@link View#onAttachedToWindow()}
+   */
+  void onAttachedToWindow();
+
+  /**
+   * Must be called from {@link View#onDetachedFromWindow()}
+   */
+  void onDetachedFromWindow();
+
+  /**
+   * Must be called from {@link View#onRestoreInstanceState(Parcelable)}
+   *
+   * @param state The parcelable state
+   */
+  void onRestoreInstanceState(Parcelable state);
+
+  /**
+   * Save the instatnce state
+   *
+   * @return The state with all the saved data
+   */
+  Parcelable onSaveInstanceState();
+}
+/*
+ * Copyright 2017 Hannes Dorfmann.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package com.hannesdorfmann.mosby3.mvp.delegate;
+
+import android.app.Activity;
+import android.app.Application;
+import android.content.Context;
+import android.os.Bundle;
+import android.os.Parcelable;
+import android.util.Log;
+import android.view.View;
+import android.widget.FrameLayout;
+
+import androidx.annotation.NonNull;
+
+import com.hannesdorfmann.mosby3.MosbySavedState;
+import com.hannesdorfmann.mosby3.PresenterManager;
+import com.hannesdorfmann.mosby3.mvp.MvpPresenter;
+import com.hannesdorfmann.mosby3.mvp.MvpView;
+import java.util.UUID;
+
+/**
+ * The mvp delegate used for everything that derives from {@link View} like {@link FrameLayout}
+ * etc.
+ *
+ * <p>
+ * The following methods must be called from the corresponding View lifecycle method:
+ * <ul>
+ * <li>{@link #onAttachedToWindow()}</li>
+ * <li>{@link #onDetachedFromWindow()}</li>
+ * </ul>
+ * </p>
+ *
+ * @author Hannes Dorfmann
+ * @since 1.1.0
+ */
+public class ViewGroupMvpDelegateImpl<V extends MvpView, P extends MvpPresenter<V>>
+    implements ViewGroupMvpDelegate<V, P>, Application.ActivityLifecycleCallbacks {
+
+  // TODO allow custom save state hook in
+
+  public static boolean DEBUG = false;
+  private static final String DEBUG_TAG = "ViewGroupMvpDelegateImp";
+
+  private ViewGroupDelegateCallback<V, P> delegateCallback;
+  private String mosbyViewId;
+  private final boolean keepPresenterDuringScreenOrientationChange;
+  private final Activity activity;
+  private final boolean isInEditMode;
+
+  private boolean checkedActivityFinishing = false;
+  private boolean presenterDetached = false;
+  private boolean presenterDestroyed = false;
+
+  public ViewGroupMvpDelegateImpl(@NonNull View view,
+      @NonNull ViewGroupDelegateCallback<V, P> delegateCallback,
+      boolean keepPresenterDuringScreenOrientationChange) {
+    if (view == null) {
+      throw new NullPointerException("View is null!");
+    }
+
+    if (delegateCallback == null) {
+      throw new NullPointerException("MvpDelegateCallback is null!");
+    }
+
+    this.delegateCallback = delegateCallback;
+    this.keepPresenterDuringScreenOrientationChange = keepPresenterDuringScreenOrientationChange;
+
+    isInEditMode = view.isInEditMode();
+
+    if (!isInEditMode) {
+      this.activity = PresenterManager.getActivity(delegateCallback.getContext());
+      this.activity.getApplication().registerActivityLifecycleCallbacks(this);
+    } else {
+      this.activity = null;
+    }
+  }
+
+  /**
+   * Generates the unique (mosby internal) viewState id and calls {@link
+   * MvpDelegateCallback#createPresenter()}
+   * to create a new presenter instance
+   *
+   * @return The new created presenter instance
+   */
+  protected P createViewIdAndCreatePresenter() {
+
+    P presenter = delegateCallback.createPresenter();
+    if (presenter == null) {
+      throw new NullPointerException("Presenter returned from createPresenter() is null.");
+    }
+    if (keepPresenterDuringScreenOrientationChange) {
+      Context context = delegateCallback.getContext();
+      mosbyViewId = UUID.randomUUID().toString();
+      PresenterManager.putPresenter(PresenterManager.getActivity(context), mosbyViewId, presenter);
+    }
+    return presenter;
+  }
+
+  @NonNull private Context getContext() {
+    Context c = delegateCallback.getContext();
+    if (c == null) {
+      throw new NullPointerException("Context returned from " + delegateCallback + " is null");
+    }
+    return c;
+  }
+
+  @Override public void onAttachedToWindow() {
+    if (isInEditMode) return;
+
+    P presenter = null;
+    if (mosbyViewId == null) {
+      // No presenter available,
+      // Activity is starting for the first time (or keepPresenterInstance == false)
+      presenter = createViewIdAndCreatePresenter();
+      if (DEBUG) {
+        Log.d(DEBUG_TAG, "new Presenter instance created: " + presenter);
+      }
+    } else {
+      presenter = PresenterManager.getPresenter(activity, mosbyViewId);
+      if (presenter == null) {
+        // Process death,
+        // hence no presenter with the given viewState id stored, although we have a viewState id
+        presenter = createViewIdAndCreatePresenter();
+        if (DEBUG) {
+          Log.d(DEBUG_TAG,
+              "No Presenter instance found in cache, although MosbyView ID present. This was caused by process death, therefore new Presenter instance created: "
+                  + presenter);
+        }
+      } else {
+        if (DEBUG) {
+          Log.d(DEBUG_TAG, "Presenter instance reused from internal cache: " + presenter);
+        }
+      }
+    }
+
+    // presenter is ready, so attach viewState
+    V view = delegateCallback.getMvpView();
+    if (view == null) {
+      throw new NullPointerException(
+          "MvpView returned from getMvpView() is null. Returned by " + delegateCallback);
+    }
+
+    if (presenter == null) {
+      throw new IllegalStateException(
+          "Oops, Presenter is null. This seems to be a Mosby internal bug. Please report this issue here: https://github.com/sockeqwe/mosby/issues");
+    }
+
+    /*
+    if (viewStateWillBeRestored) {
+      delegateCallback.setRestoringViewState(true);
+    }
+    */
+
+    delegateCallback.setPresenter(presenter);
+    presenter.attachView(view);
+
+    /*
+    if (viewStateWillBeRestored) {
+      delegateCallback.setRestoringViewState(false);
+    }
+    */
+
+    if (DEBUG) {
+      Log.d(DEBUG_TAG,
+          "MvpView attached to Presenter. MvpView: " + view + "   Presenter: " + presenter);
+    }
+  }
+
+  /**
+   * Must be called from {@link View#onSaveInstanceState()}
+   */
+  public Parcelable onSaveInstanceState() {
+    if (isInEditMode) return null;
+
+    Parcelable superState = delegateCallback.superOnSaveInstanceState();
+
+    if (keepPresenterDuringScreenOrientationChange) {
+      return new MosbySavedState(superState, mosbyViewId);
+    } else {
+      return superState;
+    }
+  }
+
+  /**
+   * Restore the data from SavedState
+   *
+   * @param state The state to read data from
+   */
+  private void restoreSavedState(MosbySavedState state) {
+    mosbyViewId = state.getMosbyViewId();
+  }
+
+  /**
+   * Must be called from {@link View#onRestoreInstanceState(Parcelable)}
+   */
+  public void onRestoreInstanceState(Parcelable state) {
+    if (isInEditMode) return;
+
+    if (!(state instanceof MosbySavedState)) {
+      delegateCallback.superOnRestoreInstanceState(state);
+      return;
+    }
+
+    MosbySavedState savedState = (MosbySavedState) state;
+    restoreSavedState(savedState);
+    delegateCallback.superOnRestoreInstanceState(savedState.getSuperState());
+  }
+
+  @Override public void onDetachedFromWindow() {
+    if (isInEditMode) return;
+
+    detachPresenterIfNotDoneYet();
+
+    if (!checkedActivityFinishing) {
+
+      boolean destroyPermanently = !ActivityMvpDelegateImpl.retainPresenterInstance(
+          keepPresenterDuringScreenOrientationChange, activity);
+
+      if (destroyPermanently) {
+        destroyPresenterIfNotDoneYet();
+      } else if (!activity.isChangingConfigurations()) {
+        // View removed manually from screen
+        destroyPresenterIfNotDoneYet();
+      }
+    } // else --> see onActivityDestroyed()
+  }
+
+  @Override public void onActivityDestroyed(Activity activity) {
+
+    if (activity == this.activity) {
+      // The hosting activity of this view has been destroyed, so time to destroy the presenter too?
+
+      activity.getApplication().unregisterActivityLifecycleCallbacks(this);
+      checkedActivityFinishing = true;
+
+      boolean destroyedPermanently = !ActivityMvpDelegateImpl.retainPresenterInstance(
+          keepPresenterDuringScreenOrientationChange, activity);
+
+      if (destroyedPermanently) {
+        // Whole activity will be destroyed
+        detachPresenterIfNotDoneYet();
+        destroyPresenterIfNotDoneYet();
+      }
+    }
+
+  }
+
+  @Override public void onActivityCreated(Activity activity, Bundle savedInstanceState) {
+  }
+
+  @Override public void onActivityStarted(Activity activity) {
+  }
+
+  @Override public void onActivityResumed(Activity activity) {
+  }
+
+  @Override public void onActivityPaused(Activity activity) {
+  }
+
+  @Override public void onActivityStopped(Activity activity) {
+  }
+
+  @Override public void onActivitySaveInstanceState(Activity activity, Bundle outState) {
+  }
+
+  private void destroyPresenterIfNotDoneYet() {
+    if (!presenterDestroyed) {
+      P presenter = delegateCallback.getPresenter();
+      if (presenter != null) {
+        presenter.destroy();
+      }
+      presenterDestroyed = true;
+      activity.getApplication().unregisterActivityLifecycleCallbacks(this);
+      if (DEBUG) {
+        Log.d(DEBUG_TAG, "Presenter destroyed: " + presenter);
+      }
+
+      if (mosbyViewId != null) {
+        // mosbyViewId == null if keepPresenterDuringScreenOrientationChange == false
+        PresenterManager.remove(activity, mosbyViewId);
+      }
+      mosbyViewId = null;
+    }
+  }
+
+  private void detachPresenterIfNotDoneYet() {
+    if (!presenterDetached) {
+      P presenter = delegateCallback.getPresenter();
+      if (presenter != null) {
+        presenter.detachView();
+      }
+      presenterDetached = true;
+      if (DEBUG) {
+        Log.d(DEBUG_TAG,
+            "view " + delegateCallback.getMvpView() + " detached from Presenter " + presenter);
+      }
+    }
+  }
+}
 <manifest xmlns:android="http://schemas.android.com/apk/res/android"
-    package="com.cnlive.strike.network" />
+    package="com.cnlive.strike.network">
+
+    <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
+    <uses-permission android:name="android.permission.INTERNET" />
+</manifest>
+package com.cnlive.core.network.converter;
+
+import com.google.gson.Gson;
+import com.google.gson.TypeAdapter;
+import com.google.gson.reflect.TypeToken;
+
+import java.lang.annotation.Annotation;
+import java.lang.reflect.Type;
+
+import okhttp3.RequestBody;
+import okhttp3.ResponseBody;
+import retrofit2.Converter;
+import retrofit2.Retrofit;
+
+public final class GsonConverterFactory extends Converter.Factory {
+
+    private boolean decode = false;
+
+    /**
+     * Create an instance using a default {@link Gson} instance for conversion. Encoding to JSON and
+     * decoding from JSON (when no charset is specified by a header) will use UTF-8.
+     */
+    public static GsonConverterFactory create() {
+        return create(new Gson(), false);
+    }
+
+    public static GsonConverterFactory create(boolean decode) {
+        return create(new Gson(), decode);
+    }
+
+    /**
+     * Create an instance using {@code gson} for conversion. Encoding to JSON and
+     * decoding from JSON (when no charset is specified by a header) will use UTF-8.
+     */
+    @SuppressWarnings("ConstantConditions") // Guarding public API nullability.
+    public static GsonConverterFactory create(Gson gson, boolean decode) {
+        if (gson == null) throw new NullPointerException("gson == null");
+        return new GsonConverterFactory(gson, decode);
+    }
+
+    private final Gson gson;
+
+    private GsonConverterFactory(Gson gson, boolean decode) {
+        this.gson = gson;
+        this.decode = decode;
+    }
+
+    @Override
+    public Converter<ResponseBody, ?> responseBodyConverter(Type type, Annotation[] annotations,
+                                                            Retrofit retrofit) {
+        TypeAdapter<?> adapter = gson.getAdapter(TypeToken.get(type));
+        return new GsonResponseBodyConverter<>(gson, adapter, decode);
+    }
+
+    @Override
+    public Converter<?, RequestBody> requestBodyConverter(Type type,
+                                                          Annotation[] parameterAnnotations, Annotation[] methodAnnotations, Retrofit retrofit) {
+        TypeAdapter<?> adapter = gson.getAdapter(TypeToken.get(type));
+        return new GsonRequestBodyConverter<>(gson, adapter);
+    }
+}
+package com.cnlive.core.network.converter;
+
+import com.google.gson.Gson;
+import com.google.gson.TypeAdapter;
+import com.google.gson.stream.JsonWriter;
+
+import java.io.IOException;
+import java.io.OutputStreamWriter;
+import java.io.Writer;
+import java.nio.charset.Charset;
+
+import okhttp3.MediaType;
+import okhttp3.RequestBody;
+import okio.Buffer;
+import retrofit2.Converter;
+
+final class GsonRequestBodyConverter<T> implements Converter<T, RequestBody> {
+    private static final MediaType MEDIA_TYPE = MediaType.parse("application/json; charset=UTF-8");
+    private static final Charset UTF_8 = Charset.forName("UTF-8");
+
+    private final Gson gson;
+    private final TypeAdapter<T> adapter;
+
+    GsonRequestBodyConverter(Gson gson, TypeAdapter<T> adapter) {
+        this.gson = gson;
+        this.adapter = adapter;
+    }
+
+    @Override
+    public RequestBody convert(T value) throws IOException {
+        Buffer buffer = new Buffer();
+        Writer writer = new OutputStreamWriter(buffer.outputStream(), UTF_8);
+        JsonWriter jsonWriter = gson.newJsonWriter(writer);
+        adapter.write(jsonWriter, value);
+        jsonWriter.close();
+        return RequestBody.create(MEDIA_TYPE, buffer.readByteString());
+    }
+}
 \ No newline at end of file
+package com.cnlive.core.network.converter;
+
+import com.cnlive.core.libs.base.util.StringUtils;
+import com.google.gson.Gson;
+import com.google.gson.TypeAdapter;
+import com.google.gson.stream.JsonReader;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.Reader;
+
+import okhttp3.ResponseBody;
+import retrofit2.Converter;
+
+final class GsonResponseBodyConverter<T> implements Converter<ResponseBody, T> {
+    private boolean decode;
+    private final Gson gson;
+    private final TypeAdapter<T> adapter;
+
+    GsonResponseBodyConverter(Gson gson, TypeAdapter<T> adapter, boolean decode) {
+        this.gson = gson;
+        this.adapter = adapter;
+        this.decode = decode;
+    }
+
+    @Override
+    public T convert(ResponseBody value) throws IOException {
+        if (decode) {
+            try {
+                return adapter.fromJson(convert(value.charStream()));
+            } finally {
+                value.close();
+            }
+        } else {
+            JsonReader jsonReader = gson.newJsonReader(value.charStream());
+            try {
+                return adapter.read(jsonReader);
+            } finally {
+                value.close();
+            }
+        }
+    }
+
+    private static String convert(Reader reader) throws IOException {
+        BufferedReader r = new BufferedReader(reader);
+        StringBuilder b = new StringBuilder();
+        String line;
+        while ((line = r.readLine()) != null) b.append(line);
+        return StringUtils.decode(b.toString());
+    }
+}
 \ No newline at end of file
+package com.cnlive.core.network.interceptor;
+
+
+import android.content.Context;
+
+import com.cnlive.core.libs.base.util.NetworkUtil;
+
+import java.io.IOException;
+
+import okhttp3.Interceptor;
+import okhttp3.Request;
+import okhttp3.Response;
+
+class ClientInterceptor implements Interceptor {
+
+    private Context mContext;
+
+    ClientInterceptor(Context context) {
+        mContext = context;
+    }
+
+    @Override
+    public Response intercept(Chain chain) throws IOException {
+        Request request = chain.request();
+
+        Response response = chain.proceed(request);
+        if (NetworkUtil.isConnectInternet(mContext)) {
+            int maxAge = 60 * 60; // read from cache for 1 minute
+            response.newBuilder()
+                    .addHeader("Cache-Control", "public, max-age=" + maxAge)
+                    .build();
+
+        } else {
+            int maxStale = 60 * 60 * 24 * 28; // tolerate 4-weeks stale
+            response.newBuilder()
+                    .addHeader("Cache-Control", "public, only-if-cached, max-stale=" + maxStale)
+                    .build();
+        }
+
+        return response;
+    }
+}
 \ No newline at end of file
+package com.cnlive.core.network.interceptor;
+
+
+import com.cnlive.core.network.util.SignUtil;
+import com.cnlive.core.libs.base.application.AppConfig;
+import com.cnlive.libs.encipher.CNLiveEncipher;
+
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.Map;
+
+import okhttp3.FormBody;
+import okhttp3.HttpUrl;
+import okhttp3.Interceptor;
+import okhttp3.MultipartBody;
+import okhttp3.Request;
+import okhttp3.RequestBody;
+import okhttp3.Response;
+
+public class DESEncryptInterceptor implements Interceptor {
+    @Override
+    public Response intercept(Chain chain) throws IOException {
+        Request request = chain.request();
+
+        if (request.body() instanceof FormBody) {
+            //处理方式 1
+            Map<String, String> parameter = new HashMap<>();
+
+            FormBody body = ((FormBody) request.body());
+            FormBody.Builder builder = new FormBody.Builder();
+
+            for (int i = 0; i < body.size(); i++) {
+                parameter.put(body.name(i), body.value(i));
+            }
+
+            String param = SignUtil.mapJoin(parameter, false);
+
+            String encrypt = CNLiveEncipher.encryptDES(AppConfig.getAppId(), param);
+
+            Map<String, String> paramete = new HashMap<>();
+            paramete.put("id", AppConfig.getAppId());
+            paramete.put("param", encrypt);
+
+            for (Map.Entry<String, String> entity : SignUtil.getOpenSignMap(paramete).entrySet()) {
+                builder.addEncoded(entity.getKey(), entity.getValue());
+            }
+            RequestBody newBody = builder.build();
+
+            Request newRequest = request.newBuilder()
+                    .method(request.method(), newBody)
+                    .url(request.url())
+                    .build();
+            return chain.proceed(newRequest);
+        } else if (request.body() instanceof MultipartBody) {
+            //处理方式 2 (暂时不签名)
+        } else {
+            //处理方式 3
+            HttpUrl.Builder authorizedUrlBuilder = request.url().newBuilder();
+
+            Map<String, String> parameter = new HashMap<>();
+
+            for (String key : request.url().queryParameterNames()) {
+                parameter.put(key, request.url().queryParameter(key));
+                authorizedUrlBuilder.removeAllQueryParameters(key);
+            }
+
+            String param = SignUtil.mapJoin(parameter, false);
+
+            String encrypt = CNLiveEncipher.encryptDES(AppConfig.getAppId(), param);
+
+            Map<String, String> paramete = new HashMap<>();
+            paramete.put("id", AppConfig.getAppId());
+            paramete.put("param", encrypt);
+
+            for (Map.Entry<String, String> entity : SignUtil.getOpenSignMap(paramete).entrySet()) {
+                authorizedUrlBuilder.addQueryParameter(entity.getKey(), entity.getValue());
+            }
+
+            authorizedUrlBuilder.scheme(request.url().scheme());
+            authorizedUrlBuilder.host(request.url().host());
+
+            Request newRequest = request.newBuilder()
+                    .method(request.method(), request.body())
+                    .url(authorizedUrlBuilder.build())
+                    .build();
+            return chain.proceed(newRequest);
+        }
+
+
+        return chain.proceed(request);
+    }
+
+
+}
 \ No newline at end of file
+package com.cnlive.core.network.interceptor;
+
+
+import java.io.IOException;
+
+import okhttp3.Interceptor;
+import okhttp3.Request;
+import okhttp3.Response;
+
+public class DefaultEncryptInterceptor implements Interceptor {
+    @Override
+    public Response intercept(Chain chain) throws IOException {
+        Request request = chain.request();
+        return chain.proceed(request);
+    }
+}
 \ No newline at end of file
+package com.cnlive.core.network.interceptor;
+
+
+import com.cnlive.core.network.util.SignUtil;
+
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.Map;
+
+import okhttp3.FormBody;
+import okhttp3.HttpUrl;
+import okhttp3.Interceptor;
+import okhttp3.MultipartBody;
+import okhttp3.Request;
+import okhttp3.RequestBody;
+import okhttp3.Response;
+
+public class NetPPEncryptInterceptor implements Interceptor {
+    @Override
+    public Response intercept(Chain chain) throws IOException {
+        Request request = chain.request();
+
+        if (request.body() instanceof FormBody) {
+            //处理方式 1
+            Map<String, String> parameter = new HashMap<>();
+
+            FormBody body = ((FormBody) request.body());
+            FormBody.Builder builder = new FormBody.Builder();
+
+            for (int i = 0; i < body.size(); i++) {
+                parameter.put(body.name(i), body.value(i));
+            }
+
+            for (Map.Entry<String, String> entity : SignUtil.getNetPPSignString(parameter).entrySet()) {
+                builder.addEncoded(entity.getKey(), entity.getValue());
+            }
+
+            RequestBody newBody = builder.build();
+
+            Request newRequest = request.newBuilder()
+                    .method(request.method(), newBody)
+                    .url(request.url())
+                    .build();
+            return chain.proceed(newRequest);
+        } else if (request.body() instanceof MultipartBody) {
+            //处理方式 2 (暂时不签名)
+        } else {
+            if ("POST".equals(request.method())) {
+                //处理方式 3
+                HttpUrl.Builder authorizedUrlBuilder = request.url().newBuilder();
+                Map<String, String> parameter = new HashMap<>();
+
+                for (String key : request.url().queryParameterNames()) {
+                    parameter.put(key, request.url().queryParameter(key));
+                    authorizedUrlBuilder.removeAllQueryParameters(key);
+                }
+
+                FormBody.Builder builder = new FormBody.Builder();
+
+                for (Map.Entry<String, String> entity : SignUtil.getNetPPSignString(parameter).entrySet()) {
+                    builder.add(entity.getKey(), entity.getValue());
+                }
+
+                RequestBody newBody = builder.build();
+
+                Request newRequest = request.newBuilder()
+                        .method(request.method(), newBody)
+                        .url(authorizedUrlBuilder.build())
+                        .build();
+                return chain.proceed(newRequest);
+            } else {
+                //处理方式 3
+                HttpUrl.Builder authorizedUrlBuilder = request.url().newBuilder();
+                Map<String, String> parameter = new HashMap<>();
+
+                for (String key : request.url().queryParameterNames()) {
+                    parameter.put(key, request.url().queryParameter(key));
+                    authorizedUrlBuilder.removeAllQueryParameters(key);
+                }
+
+                for (Map.Entry<String, String> entity : SignUtil.getNetPPSignString(parameter).entrySet()) {
+                    authorizedUrlBuilder.addQueryParameter(entity.getKey(), entity.getValue());
+                }
+
+                authorizedUrlBuilder.scheme(request.url().scheme());
+                authorizedUrlBuilder.host(request.url().host());
+
+                Request newRequest = request.newBuilder()
+                        .method(request.method(), request.body())
+                        .url(authorizedUrlBuilder.build())
+                        .build();
+                return chain.proceed(newRequest);
+            }
+        }
+
+
+        return chain.proceed(request);
+    }
+
+
+}
 \ No newline at end of file
+package com.cnlive.core.network.interceptor;
+
+
+
+import com.cnlive.core.network.util.SignUtil;
+
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.Map;
+
+import okhttp3.FormBody;
+import okhttp3.HttpUrl;
+import okhttp3.Interceptor;
+import okhttp3.MultipartBody;
+import okhttp3.Request;
+import okhttp3.RequestBody;
+import okhttp3.Response;
+
+public class NetPPPayEncryptInterceptor implements Interceptor {
+    @Override
+    public Response intercept(Chain chain) throws IOException {
+        Request request = chain.request();
+
+        if (request.body() instanceof FormBody) {
+            //处理方式 1
+            Map<String, String> parameter = new HashMap<>();
+
+            FormBody body = ((FormBody) request.body());
+            FormBody.Builder builder = new FormBody.Builder();
+
+            for (int i = 0; i < body.size(); i++) {
+                parameter.put(body.name(i), body.value(i));
+            }
+
+            for (Map.Entry<String, String> entity : SignUtil.getNetPPPaySignString(parameter).entrySet()) {
+                builder.addEncoded(entity.getKey(), entity.getValue());
+            }
+
+            RequestBody newBody = builder.build();
+
+            Request newRequest = request.newBuilder()
+                    .method(request.method(), newBody)
+                    .url(request.url())
+                    .build();
+            return chain.proceed(newRequest);
+        } else if (request.body() instanceof MultipartBody) {
+            //处理方式 2 (暂时不签名)
+        } else {
+            if ("POST".equals(request.method())) {
+                //处理方式 3
+                HttpUrl.Builder authorizedUrlBuilder = request.url().newBuilder();
+
+                Map<String, String> parameter = new HashMap<>();
+
+                for (String key : request.url().queryParameterNames()) {
+                    parameter.put(key, request.url().queryParameter(key));
+                    authorizedUrlBuilder.removeAllQueryParameters(key);
+                }
+
+                FormBody.Builder builder = new FormBody.Builder();
+
+                for (Map.Entry<String, String> entity : SignUtil.getNetPPPaySignString(parameter).entrySet()) {
+                    builder.add(entity.getKey(), entity.getValue());
+                }
+
+                RequestBody newBody = builder.build();
+
+                Request newRequest = request.newBuilder()
+                        .method(request.method(), newBody)
+                        .url(authorizedUrlBuilder.build())
+                        .build();
+                return chain.proceed(newRequest);
+            }else{
+                //处理方式 3
+                HttpUrl.Builder authorizedUrlBuilder = request.url().newBuilder();
+
+                Map<String, String> parameter = new HashMap<>();
+
+                for (String key : request.url().queryParameterNames()) {
+                    parameter.put(key, request.url().queryParameter(key));
+                    authorizedUrlBuilder.removeAllQueryParameters(key);
+                }
+
+                for (Map.Entry<String, String> entity : SignUtil.getNetPPPaySignString(parameter).entrySet()) {
+                    authorizedUrlBuilder.addQueryParameter(entity.getKey(), entity.getValue());
+                }
+
+                authorizedUrlBuilder.scheme(request.url().scheme());
+                authorizedUrlBuilder.host(request.url().host());
+
+                Request newRequest = request.newBuilder()
+                        .method(request.method(), request.body())
+                        .url(authorizedUrlBuilder.build())
+                        .build();
+                return chain.proceed(newRequest);
+            }
+        }
+
+
+        return chain.proceed(request);
+    }
+
+
+}
 \ No newline at end of file
+package com.cnlive.core.network.interceptor;
+
+import android.content.Context;
+
+import com.cnlive.core.libs.base.util.NetworkUtil;
+
+import java.io.IOException;
+
+import okhttp3.Interceptor;
+import okhttp3.Request;
+
+/**
+ * Created by xiansong on 2018/4/4.
+ */
+
+public class OffLineInterceptor implements Interceptor {
+
+    private static final int TIMEOUT_DISCONNECT = 60 * 60 * 24 * 7; //7天
+
+    private Context mContext;
+
+    public OffLineInterceptor(Context context) {
+        mContext = context;
+    }
+
+    @Override
+    public okhttp3.Response intercept(Chain chain) throws IOException {
+        Request request = chain.request();
+        //离线的时候为7天的缓存。
+        if (!NetworkUtil.isConnectInternet(mContext)) {
+            request = request.newBuilder()
+                    .header("Cache-Control", "public, only-if-cached, max-stale=" + TIMEOUT_DISCONNECT)
+                    .build();
+        }
+        return chain.proceed(request);
+    }
+}
+package com.cnlive.core.network.interceptor;
+
+import java.io.IOException;
+
+import okhttp3.Interceptor;
+
+/**
+ * Created by xiansong on 2018/4/4.
+ */
+
+public class OnLineInterceptor implements Interceptor {
+
+    private static final int TIMEOUT_CONNECT = 5; //5秒
+
+    @Override
+    public okhttp3.Response intercept(Chain chain) throws IOException {
+        //获取retrofit @headers里面的参数，参数可以自己定义，在本例我自己定义的是cache，跟@headers里面对应就可以了
+        String cache = chain.request().header("cache");
+        okhttp3.Response originalResponse = chain.proceed(chain.request());
+        String cacheControl = originalResponse.header("Cache-Control");
+        //如果cacheControl为空，就让他TIMEOUT_CONNECT秒的缓存，本例是5秒，方便观察。注意这里的cacheControl是服务器返回的
+        if (cacheControl == null) {
+            //如果cache没值，缓存时间为TIMEOUT_CONNECT，有的话就为cache的值
+            if (cache == null || "".equals(cache)) {
+                cache = TIMEOUT_CONNECT + "";
+            }
+            originalResponse = originalResponse.newBuilder()
+                    .header("Cache-Control", "public, max-age=" + cache)
+                    .build();
+            return originalResponse;
+        } else {
+            return originalResponse;
+        }
+    }
+}
 \ No newline at end of file
+package com.cnlive.core.network.interceptor;
+
+
+import com.cnlive.core.network.util.SignUtil;
+
+import java.io.IOException;
+import java.net.URLEncoder;
+import java.util.HashMap;
+import java.util.Map;
+
+import okhttp3.FormBody;
+import okhttp3.HttpUrl;
+import okhttp3.Interceptor;
+import okhttp3.MultipartBody;
+import okhttp3.Request;
+import okhttp3.RequestBody;
+import okhttp3.Response;
+
+public class SignEncrypt2Interceptor implements Interceptor {
+
+    private boolean valueUrlencode = false;
+
+    public SignEncrypt2Interceptor() {
+
+    }
+
+    public SignEncrypt2Interceptor(boolean valueUrlencode) {
+        this.valueUrlencode = valueUrlencode;
+    }
+
+    @Override
+    public Response intercept(Chain chain) throws IOException {
+        Request request = chain.request();
+
+        if (request.body() instanceof FormBody) {
+            //处理方式 1
+            Map<String, String> parameter = new HashMap<>();
+
+            FormBody body = ((FormBody) request.body());
+            FormBody.Builder builder = new FormBody.Builder();
+
+            for (int i = 0; i < body.size(); i++) {
+                parameter.put(body.name(i), body.value(i));
+            }
+
+            for (Map.Entry<String, String> entity : SignUtil.getOpenSignMap(parameter, valueUrlencode).entrySet()) {
+                builder.add(entity.getKey(), URLEncoder.encode(entity.getValue(), "UTF-8"));
+            }
+            RequestBody newBody = builder.build();
+
+            Request newRequest = request.newBuilder()
+                    .method(request.method(), newBody)
+                    .url(request.url())
+                    .build();
+            return chain.proceed(newRequest);
+        } else if (request.body() instanceof MultipartBody) {
+            //处理方式 2 (暂时不签名)
+        } else {
+            if ("POST".equals(request.method())) {
+                HttpUrl.Builder authorizedUrlBuilder = request.url().newBuilder();
+
+                Map<String, String> parameter = new HashMap<>();
+
+                for (String key : request.url().queryParameterNames()) {
+                    parameter.put(key, request.url().queryParameter(key));
+                    authorizedUrlBuilder.removeAllQueryParameters(key);
+                }
+
+                FormBody.Builder builder = new FormBody.Builder();
+
+                for (Map.Entry<String, String> entity : SignUtil.getOpenSignMap(parameter, valueUrlencode).entrySet()) {
+                    builder.add(entity.getKey(), URLEncoder.encode(entity.getValue(), "UTF-8"));
+                }
+                RequestBody newBody = builder.build();
+
+                Request newRequest = request.newBuilder()
+                        .method(request.method(), newBody)
+                        .url(authorizedUrlBuilder.build())
+                        .build();
+                return chain.proceed(newRequest);
+            } else {
+                HttpUrl.Builder authorizedUrlBuilder = request.url().newBuilder();
+
+                Map<String, String> parameter = new HashMap<>();
+
+                for (String key : request.url().queryParameterNames()) {
+                    parameter.put(key, request.url().queryParameter(key));
+                    authorizedUrlBuilder.removeAllQueryParameters(key);
+                }
+
+                for (Map.Entry<String, String> entity : SignUtil.getOpenSignMap(parameter, valueUrlencode).entrySet()) {
+                    authorizedUrlBuilder.addQueryParameter(entity.getKey(), URLEncoder.encode(entity.getValue(), "UTF-8"));
+                }
+
+                authorizedUrlBuilder.scheme(request.url().scheme());
+                authorizedUrlBuilder.host(request.url().host());
+
+                Request newRequest = request.newBuilder()
+                        .method(request.method(), request.body())
+                        .url(authorizedUrlBuilder.build())
+                        .build();
+                return chain.proceed(newRequest);
+            }
+        }
+
+        return chain.proceed(request);
+    }
+
+
+}
 \ No newline at end of file
+package com.cnlive.core.network.interceptor;
+
+
+
+import com.cnlive.core.network.util.SignUtil;
+
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.Map;
+
+import okhttp3.FormBody;
+import okhttp3.HttpUrl;
+import okhttp3.Interceptor;
+import okhttp3.MultipartBody;
+import okhttp3.Request;
+import okhttp3.RequestBody;
+import okhttp3.Response;
+
+public class SignEncryptInterceptor implements Interceptor {
+
+    private boolean valueUrlencode = false;
+
+    public SignEncryptInterceptor() {
+
+    }
+
+    public SignEncryptInterceptor(boolean valueUrlencode) {
+        this.valueUrlencode = valueUrlencode;
+    }
+
+    @Override
+    public Response intercept(Chain chain) throws IOException {
+        Request request = chain.request();
+
+        if (request.body() instanceof FormBody) {
+            //处理方式 1
+            Map<String, String> parameter = new HashMap<>();
+
+            FormBody body = ((FormBody) request.body());
+            FormBody.Builder builder = new FormBody.Builder();
+
+            for (int i = 0; i < body.size(); i++) {
+                parameter.put(body.name(i), body.value(i));
+            }
+
+            for (Map.Entry<String, String> entity : SignUtil.getOpenSignMap(parameter, valueUrlencode).entrySet()) {
+                builder.add(entity.getKey(), entity.getValue());
+            }
+            RequestBody newBody = builder.build();
+
+            Request newRequest = request.newBuilder()
+                    .method(request.method(), newBody)
+                    .url(request.url())
+                    .build();
+            return chain.proceed(newRequest);
+        } else if (request.body() instanceof MultipartBody) {
+            //处理方式 2 (暂时不签名)
+        } else {
+            if ("POST".equals(request.method())) {
+                HttpUrl.Builder authorizedUrlBuilder = request.url().newBuilder();
+
+                Map<String, String> parameter = new HashMap<>();
+
+                for (String key : request.url().queryParameterNames()) {
+                    parameter.put(key, request.url().queryParameter(key));
+                    authorizedUrlBuilder.removeAllQueryParameters(key);
+                }
+
+                FormBody.Builder builder = new FormBody.Builder();
+
+                for (Map.Entry<String, String> entity : SignUtil.getOpenSignMap(parameter, valueUrlencode).entrySet()) {
+                    builder.add(entity.getKey(), entity.getValue());
+                }
+                RequestBody newBody = builder.build();
+
+                Request newRequest = request.newBuilder()
+                        .method(request.method(), newBody)
+                        .url(authorizedUrlBuilder.build())
+                        .build();
+                return chain.proceed(newRequest);
+            } else {
+                HttpUrl.Builder authorizedUrlBuilder = request.url().newBuilder();
+
+                Map<String, String> parameter = new HashMap<>();
+
+                for (String key : request.url().queryParameterNames()) {
+                    parameter.put(key, request.url().queryParameter(key));
+                    authorizedUrlBuilder.removeAllQueryParameters(key);
+                }
+
+                for (Map.Entry<String, String> entity : SignUtil.getOpenSignMap(parameter, valueUrlencode).entrySet()) {
+                    authorizedUrlBuilder.addQueryParameter(entity.getKey(), entity.getValue());
+                }
+
+                authorizedUrlBuilder.scheme(request.url().scheme());
+                authorizedUrlBuilder.host(request.url().host());
+
+                Request newRequest = request.newBuilder()
+                        .method(request.method(), request.body())
+                        .url(authorizedUrlBuilder.build())
+                        .build();
+                return chain.proceed(newRequest);
+            }
+        }
+
+        return chain.proceed(request);
+    }
+
+
+}
 \ No newline at end of file