MVP学习笔记

public class SearchCarAPI {
	private static class InstanceHolder {
	    static Api INSTANCE = ServiceFactory.createService("https://app.auto.sohu.com/", Api.class);
	}
	
	public interface Api {
	    //某品牌下的车型列表
	    @GET("car/brands/{brandId}/models")
	    Observable<Response<LinkedHashMap<String, List<CarModel>>>> getVehicleModel(@Path("brandId") int id);
	}
	
	public static Api getInstance() {
	    return InstanceHolder.INSTANCE;
	}
}

/**
* 车型数据
*/
public class CarModel {
	@SerializedName("id")
	public String modelId; //id
	@SerializedName("name")
	public String modelName; //车型名称 （A3 Limousine
	@SerializedName("minPriceGuide")
	public String minPrice; //最低报价
	@SerializedName("maxPriceGuide")
	public String maxPrice; //最高报价
	@SerializedName("whiteGroundFocusPic")
	public String modelUrl; //车型焦点图Url
}

public interface CarListDataSource {
	Observable<Response<LinkedHashMap<String, List<CarModel>>>> getCarList();
}

public class CarListRepository implements CarListDataSource {
    private BaseActivity mBaseActivity;

    private CarListRepository(BaseActivity activity){
        mBaseActivity = activity;
    }

    public static CarListRepository getInstance(BaseActivity baseActivity){
        return new CarListRepository(baseActivity);
    }
	
	
    @Override
    public Observable<Response<LinkedHashMap<String, List<CarModel>>>> getCarList() {
        return MySearchCarAPI.getInstance().getVehicleModel(191);
    }
}

public interface CarListContract {
    interface CarListView extends BaseView<CarListPresenter>{ // View提供给Presenter的接口，用于更新界面
        void showCarList(LinkedHashMap<String, List<CarModel>> carModels); // 当获取到汽车列表信息时更新界面的方法
        void showNetError(); // 当网络异常时更新界面的方法
    }
	
    interface CarListPresenter extends BasePresenter{ // Presenter提供给View的接口，用于View响应点击事件，请求获取数据
        LinkedHashMap<String, List<CarModel>> getCarListData(); // 获取汽车列表执行的方法
    }
}

public class GlSearchCarFragment extends BaseFragment implements CarListContract.CarListView{
    private static final String TAG = "GlSearchCarFragment";
	
    private TextView audiCarTxt, carListResponseTxt;
    private CarListContract.CarListPresenter mCarListPresenter;
	
    @Override
    public void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        mCarListPresenter = new CarListPresenter(this,
	                                                    CarListRepository.getInstance((BaseActivity) getActivity()));
    }
	
    @Override
    protected int getLayoutResource() {
        return R.layout.fragment_searchcar;
    }
	
    @Override
    protected void onInitView() {
        audiCarTxt = (TextView) findViewById(R.id.audi_car_txt);
        carListResponseTxt = (TextView) findViewById(R.id.response_car_list_txt);
        audiCarTxt.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                Log.e(TAG, "text click!");
                carListResponseTxt.setText("暂无数据");
                mCarListPresenter.getCarListData();
            }
        });
        carListResponseTxt.setText("暂无数据");
    }
	
    @Override
    public void setPresenter(CarListContract.CarListPresenter presenter) {
        mCarListPresenter = presenter;
    }
	
    @Override
    public void showCarList(LinkedHashMap<String, List<CarModel>> carModelMaps) {
        if(carModelMaps.size()<=0){
            carListResponseTxt.setText("未查到汽车！");
        }else {
            StringBuilder stringBuilder = new StringBuilder();
            for(String key:carModelMaps.keySet()){
                stringBuilder.append(key+"\n");
                for(CarModel carModel:carModelMaps.get(key)){
                    String s = "汽车Id： " + carModel.modelId
                                + "\n汽车名称：" + carModel.modelName
                                + "\n最高报价：" + carModel.maxPrice
                                + "\n最低报价：" + carModel.minPrice;
                    stringBuilder.append(s+"\n");
                }
                stringBuilder.append("\n");
            }
            carListResponseTxt.setText(stringBuilder.toString());
        }
    }

    @Override
    public void showNetError() {
        carListResponseTxt.setText("网络错误，请重试！");
    }
}

public class CarListPresenter implements CarListContract.CarListPresenter {
    private CarListContract.CarListView mView;
    private CarListRepository mCarListRepository;

    public CarListPresenter(CarListContract.CarListView carListView, CarListRepository carListRepository){
    mView = carListView;
    mCarListRepository = carListRepository;
    initCallBack();
    }

    private void initCallBack(){}
	
    @Override
    public void start() {}
	
    @Override
    public void getCarListData() {
        mCarListRepository.getCarList().observeOn(AndroidSchedulers.mainThread())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(Schedulers.io())
            .subscribe(new ResponseSubscriber<LinkedHashMap<String, List<CarModel>>>() {
                @Override
                public void onSuccess(LinkedHashMap<String, List<CarModel>> feeds) {
                    mView.showCarList(feeds);
                }

                @Override
                public void onFailure(Throwable error) {
                    mView.showNetError();
                }
            });
    }
}