admin/July
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

d

Browse Source
This commit is contained in:
jianbo
2020-08-31 09:37:34 +08:00
parent 441081398e
commit ed7397402c
15 changed files with 315 additions and 146 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
app/src/main/java/com/fenghoo/seven/okgonet/HttpConstants.java
View File

@@ -30,7 +30,6 @@ public class HttpConstants {
*/
public static String URi_device_AppCustomer_fpList = URiBase + "/device/AppCustomer/fpList";
/**
* 客户列表
*/
@@ -80,6 +79,16 @@ public class HttpConstants {
*/
public static String URi_device_AppDouyin_aweme = URiBase + "/device/AppDouyin/aweme";
/**
* 私信列表
*/
public static String URi_device_AppDouyin_privateList = URiBase + "/device/AppDouyin/privateList";
/**
* 删除客户
*/
public static String URi_device_AppCustomer_deleteCus = URiBase + "/device/AppCustomer/deleteCus";
}

91
app/src/main/java/com/fenghoo/seven/okgonet/NetApi.java
View File

@@ -105,51 +105,6 @@ public class NetApi {
}
/**
* 分配列表
*/
public Observable<Response> fpList(final String uid, final String search) {
return new Observable<Response>() {
@Override
public void subscribe(final Observer<Response> observer) {
OkGo.<String>post(HttpConstants.URi_device_AppCustomer_fpList)//
.params("uid", uid)
.params("search", search)
.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() {
}
});
}
};
}
/**
* 客户列表
*/
@@ -195,52 +150,6 @@ public class NetApi {
}
/**
* 成交列表
*/
public Observable<Response> orderList(final String uid, final String search) {
return new Observable<Response>() {
@Override
public void subscribe(final Observer<Response> observer) {
OkGo.<String>post(HttpConstants.URi_device_AppCustomer_orderList)//
.params("uid", uid)
.params("search", search)
.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() {
}
});
}
};
}
/**
* 客户分配
*/