d
This commit is contained in:
@@ -427,6 +427,10 @@ public class HttpConstants {
|
||||
*/
|
||||
public static String URi_device_AppCustomer_industry = URiBase + "/device/AppCustomer/industry";
|
||||
|
||||
/**
|
||||
* 分配/成交列表详情
|
||||
*/
|
||||
public static String URi_device_AppCustomer_fpOrderInfo = URiBase + "/device/AppCustomer/fpOrderInfo";
|
||||
|
||||
|
||||
}
|
||||
|
||||
@@ -372,4 +372,53 @@ public class NetApi {
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* @description 分配/成交列表详情
|
||||
* @param customer_id 客户id
|
||||
* @return industry_id 行业id
|
||||
*/
|
||||
public Observable<Response> fpOrderInfo(final String customer_id, final String industry_id) {
|
||||
|
||||
return new Observable<Response>() {
|
||||
@Override
|
||||
public void subscribe(final Observer<Response> observer) {
|
||||
|
||||
OkGo.<String>post(HttpConstants.URi_device_AppCustomer_fpOrderInfo)
|
||||
.params("customer_id", customer_id)
|
||||
.params("industry_id", industry_id)
|
||||
.converter(new StringConvert())//
|
||||
.cacheMode(CacheMode.NO_CACHE) //无缓存模式 CacheMode.NO_CACHE
|
||||
.adapt(new ObservableResponse<String>())//
|
||||
.subscribeOn(Schedulers.io())//
|
||||
.observeOn(AndroidSchedulers.mainThread())//
|
||||
.subscribe(new io.reactivex.Observer<Response<String>>() {
|
||||
|
||||
@Override
|
||||
public void onSubscribe(@NonNull Disposable d) {
|
||||
// addDisposable(d);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void onNext(@NonNull Response<String> response) {
|
||||
observer.onNext(response);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void onError(@NonNull Throwable e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void onComplete() {
|
||||
|
||||
}
|
||||
});
|
||||
}
|
||||
};
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user