Commit 08ab60ab authored by yinjiacheng's avatar yinjiacheng

update 整理服务端接口

parent 061cbb60
...@@ -16,324 +16,305 @@ import okhttp3.MultipartBody ...@@ -16,324 +16,305 @@ import okhttp3.MultipartBody
class ApiService { class ApiService {
companion object { companion object {
// 获取短信验证码 // 文件上传
fun sendMsgCode(apiCallback: IMobileLoginCallback, requestParams: HashMap<String, String?>) { fun uploadFile(apiCallback: IUploadFileCallback, requestParams: MultipartBody.Part) {
val timeStamp = System.currentTimeMillis() val timeStamp = System.currentTimeMillis()
val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp) val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp)
val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp)
ServiceFactory.getInstance().createService(CommonService::class.java) ServiceFactory.getInstance().createService(CommonService::class.java)
.sendMsgCode(publicParamsMap, privateParamsMap) .uploadFile(publicParamsMap, requestParams)
.compose(TransformUtil.defaultSchedulers()) .compose(TransformUtil.defaultSchedulers())
.subscribe(object : HttpResultSubscriber<Any?>() { .subscribe(object : HttpResultSubscriber<Any?>() {
override fun onSuccess(result: HttpResult<Any?>?) { override fun onSuccess(result: HttpResult<Any?>?) {
apiCallback.sendSmsCodeCallBack(result) apiCallback.uploadFileCallBack(result)
} }
override fun onFailer(result: HttpResult<Any?>?) { override fun onFailer(result: HttpResult<Any?>?) {
apiCallback.sendSmsCodeCallBack(result) apiCallback.uploadFileCallBack(result)
} }
}) })
} }
// 手机号登录接口 // pushToken绑定接口
fun mobileLogin(apiCallback: IMobileLoginCallback, requestParams: HashMap<String, String?>) { fun pushTokenAndroid(requestParams: HashMap<String, String?>) {
val timeStamp = System.currentTimeMillis() val timeStamp = System.currentTimeMillis()
val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp) val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp)
val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp) val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp)
ServiceFactory.getInstance().createService(CommonService::class.java) ServiceFactory.getInstance().createService(CommonService::class.java)
.mobileLogin(publicParamsMap, privateParamsMap) .pushTokenAndroid(publicParamsMap, privateParamsMap)
.compose(TransformUtil.defaultSchedulers()) .compose(TransformUtil.defaultSchedulers())
.subscribe(object : HttpResultSubscriber<MobileLoginBean.Response?>() { .subscribe(object : HttpResultSubscriber<Any?>() {
override fun onSuccess(result: HttpResult<MobileLoginBean.Response?>?) { override fun onSuccess(result: HttpResult<Any?>?) {
apiCallback.mobileLoginCallBack(result)
} }
override fun onFailer(result: HttpResult<MobileLoginBean.Response?>?) { override fun onFailer(result: HttpResult<Any?>?) {
apiCallback.mobileLoginCallBack(result)
} }
}) })
} }
// 用户退出登录接口 // 获取短信验证码
fun userLogout(apiCallback: IUserLogoutCallBack) { fun sendMsgCode(apiCallback: IMobileLoginCallback, requestParams: HashMap<String, String?>) {
val timeStamp = System.currentTimeMillis() val timeStamp = System.currentTimeMillis()
val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp) val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp)
val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(HashMap(), timeStamp) val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp)
ServiceFactory.getInstance().createService(CommonService::class.java) ServiceFactory.getInstance().createService(CommonService::class.java)
.userLogout(publicParamsMap, privateParamsMap) .sendMsgCode(publicParamsMap, privateParamsMap)
.compose(TransformUtil.defaultSchedulers()) .compose(TransformUtil.defaultSchedulers())
.subscribe(object : HttpResultSubscriber<Any?>() { .subscribe(object : HttpResultSubscriber<Any?>() {
override fun onSuccess(result: HttpResult<Any?>?) { override fun onSuccess(result: HttpResult<Any?>?) {
apiCallback.userLogoutSuccess() apiCallback.sendSmsCodeCallBack(result)
} }
override fun onFailer(result: HttpResult<Any?>?) { override fun onFailer(result: HttpResult<Any?>?) {
apiCallback.sendSmsCodeCallBack(result)
} }
}) })
} }
// 106 获取生活号列表接口 // 手机号登录接口
fun getLifeAccountList(apiCallback: IGetLifeAccountListCallback) { fun mobileLogin(apiCallback: IMobileLoginCallback, requestParams: HashMap<String, String?>) {
val timeStamp = System.currentTimeMillis() val timeStamp = System.currentTimeMillis()
val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp) val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp)
val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(HashMap(), timeStamp) val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp)
ServiceFactory.getInstance().createService(CommonService::class.java) ServiceFactory.getInstance().createService(CommonService::class.java)
.getAccountList(publicParamsMap, privateParamsMap) .mobileLogin(publicParamsMap, privateParamsMap)
.compose(TransformUtil.defaultSchedulers()) .compose(TransformUtil.defaultSchedulers())
.subscribe(object : HttpResultSubscriber<ArrayList<LifeAccountItemBean.Response>?>() { .subscribe(object : HttpResultSubscriber<MobileLoginBean.Response?>() {
override fun onSuccess(result: HttpResult<ArrayList<LifeAccountItemBean.Response>?>?) { override fun onSuccess(result: HttpResult<MobileLoginBean.Response?>?) {
apiCallback.getLifeAccountListSuccess(result?.result) apiCallback.mobileLoginCallBack(result)
} }
override fun onFailer(result: HttpResult<ArrayList<LifeAccountItemBean.Response>?>?) { override fun onFailer(result: HttpResult<MobileLoginBean.Response?>?) {
apiCallback.getLifeAccountListFailure(result?.reason) apiCallback.mobileLoginCallBack(result)
} }
}) })
} }
// 人脸检测接口 // 用户退出登录接口
fun identifyIdOcrVerify(apiCallback: IdentifyIdOcrVerifyCallback, requestParams: HashMap<String, String?>) { fun userLogout(apiCallback: IUserLogoutCallBack) {
val timeStamp = System.currentTimeMillis() val timeStamp = System.currentTimeMillis()
val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp) val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp)
val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp) val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(HashMap(), timeStamp)
ServiceFactory.getInstance().createService(CommonService::class.java) ServiceFactory.getInstance().createService(CommonService::class.java)
.identifyIdOcrVerify(publicParamsMap, privateParamsMap) .userLogout(publicParamsMap, privateParamsMap)
.compose(TransformUtil.defaultSchedulers()) .compose(TransformUtil.defaultSchedulers())
.subscribe(object : HttpResultSubscriber<IdentifyIdOcrVerifyBean.Response?>() { .subscribe(object : HttpResultSubscriber<Any?>() {
override fun onSuccess(result: HttpResult<IdentifyIdOcrVerifyBean.Response?>?) { override fun onSuccess(result: HttpResult<Any?>?) {
apiCallback.identifyIdOcrVerifySuccess(result) apiCallback.userLogoutSuccess()
} }
override fun onFailer(result: HttpResult<IdentifyIdOcrVerifyBean.Response?>?) { override fun onFailer(result: HttpResult<Any?>?) {
apiCallback.identifyIdOcrVerifyFailure(result)
} }
}) })
} }
// 获取人脸检测token接口 // 101 身份信息校验接口
fun authPersonalGetToken(apiCallback: AuthPersonalGetTokenCallback, requestParams: HashMap<String, String?>) { fun authPersonalCheck(apiCallback: IAuthPersonalCheckCallback, requestParams: HashMap<String, String?>) {
val timeStamp = System.currentTimeMillis() val timeStamp = System.currentTimeMillis()
val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp) val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp)
val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp) val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp)
ServiceFactory.getInstance().createService(CommonService::class.java) ServiceFactory.getInstance().createService(CommonService::class.java)
.authPersonalGetToken(publicParamsMap, privateParamsMap) .authPersonalCheck(publicParamsMap, privateParamsMap)
.compose(TransformUtil.defaultSchedulers()) .compose(TransformUtil.defaultSchedulers())
.subscribe(object : HttpResultSubscriber<AuthPersonalGetTokenBean.Response?>() { .subscribe(object : HttpResultSubscriber<Any>() {
override fun onSuccess(result: HttpResult<AuthPersonalGetTokenBean.Response?>?) { override fun onSuccess(result: HttpResult<Any>?) {
apiCallback.getTokenSuccess(result) apiCallback.authPersonCheckSuccess()
} }
override fun onFailer(result: HttpResult<AuthPersonalGetTokenBean.Response?>?) { override fun onFailer(result: HttpResult<Any>?) {
apiCallback.authPersonCheckFailure(result?.reason)
} }
}) })
} }
// 获取金山云token接口 // 102 活体识别成功后回调接口
fun getKSYunToken(requestParams: HashMap<String, String?>): HttpResult<GetKSYunTokenBean.Response>? { fun authLiveIdentity(apiCallback: IAuthLiveIdentityCallback) {
val timeStamp = System.currentTimeMillis()
val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp)
val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp)
val res: HttpResult<Any?>? = ServiceFactory.getInstance().createService(CommonService::class.java)
.getKSYunToken(publicParamsMap, privateParamsMap)
.execute().body()
if (res?.code == 0) {
return HttpParamsUtils.rsaDecryptResult(res, object : TypeToken<GetKSYunTokenBean.Response>() {}.type)
} else {
val decodeResult = HttpResult<GetKSYunTokenBean.Response>()
decodeResult.code = res?.code!!
decodeResult.reason = res.reason
decodeResult.status = res.status
ToastUtil.showToast(YdBaseApplication.context, res.reason)
}
return null
}
// 获取身份证OCR接口
fun getIDCardOCR(apiCallback: IGetIDCardOCRCallback, requestParams: HashMap<String, String?>) {
val timeStamp = System.currentTimeMillis() val timeStamp = System.currentTimeMillis()
val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp) val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp)
val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp) val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(HashMap(), timeStamp)
ServiceFactory.getInstance().createService(CommonService::class.java) ServiceFactory.getInstance().createService(CommonService::class.java)
.getIDCardOCR(publicParamsMap, privateParamsMap) .authLiveIdentity(publicParamsMap, privateParamsMap)
.compose(TransformUtil.defaultSchedulers()) .compose(TransformUtil.defaultSchedulers())
.subscribe(object : HttpResultSubscriber<GetIDCardOCRBean.Response>() { .subscribe(object : HttpResultSubscriber<Any?>() {
override fun onSuccess(result: HttpResult<GetIDCardOCRBean.Response>?) { override fun onSuccess(result: HttpResult<Any?>?) {
apiCallback.getIDCardOCRSuccess(result?.result) apiCallback.authLiveIdentitySuccess()
} }
override fun onFailer(result: HttpResult<GetIDCardOCRBean.Response>?) { override fun onFailer(result: HttpResult<Any?>?) {
apiCallback.getIDCardOCRFailure(result?.status) apiCallback.authLiveIdentityFailure(result?.reason)
} }
}) })
} }
// 获取金山云ObjectId // 103 认证完成后创建生活号接口
fun getKSYunObjectId(apiCallback: IGetKSYunObjectIdCallback, requestParams: HashMap<String, String?>) { fun authComplete(apiCallbackPersonal: IAuthPersonalCompleteCallback, requestParams: HashMap<String, String?>) {
val timeStamp = System.currentTimeMillis() val timeStamp = System.currentTimeMillis()
val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp) val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp)
val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp) val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp)
ServiceFactory.getInstance().createService(CommonService::class.java) ServiceFactory.getInstance().createService(CommonService::class.java)
.getKSYunObjectId(publicParamsMap, privateParamsMap) .authComplete(publicParamsMap, privateParamsMap)
.compose(TransformUtil.defaultSchedulers()) .compose(TransformUtil.defaultSchedulers())
.subscribe(object : HttpResultSubscriber<GetKSYunObjectIdBean.Response>() { .subscribe(object : HttpResultSubscriber<AuthPersonalCompleteBean.Response?>() {
override fun onSuccess(result: HttpResult<GetKSYunObjectIdBean.Response>?) { override fun onSuccess(result: HttpResult<AuthPersonalCompleteBean.Response?>?) {
apiCallback.getKSYunObjectIdSuccess(result?.result) apiCallbackPersonal.authPersonalCompleteSuccess(result?.result)
} }
override fun onFailer(result: HttpResult<GetKSYunObjectIdBean.Response>?) { override fun onFailer(result: HttpResult<AuthPersonalCompleteBean.Response?>?) {
apiCallback.getKSYunObjectIdFailure(result?.status) apiCallbackPersonal.authPersonalCompleteFailure(result?.reason)
} }
}) })
} }
// 获取金山云Bucket // 104 检测是否可以个人认证,返回认证信息接口
fun getKSYunBucket(apiCallback: IGetKSYunBucketCallback) { fun authAuthentication(apiCallback: IAuthAuthenticationCallback) {
val timeStamp = System.currentTimeMillis() val timeStamp = System.currentTimeMillis()
val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp) val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp)
val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(HashMap(), timeStamp) val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(HashMap(), timeStamp)
ServiceFactory.getInstance().createService(CommonService::class.java) ServiceFactory.getInstance().createService(CommonService::class.java)
.getKSYunBucket(publicParamsMap, privateParamsMap) .authAuthentication(publicParamsMap, privateParamsMap)
.compose(TransformUtil.defaultSchedulers()) .compose(TransformUtil.defaultSchedulers())
.subscribe(object : HttpResultSubscriber<GetKSYunBucketBean.Response>() { .subscribe(object : HttpResultSubscriber<AuthAuthenticationBean.Response?>() {
override fun onSuccess(result: HttpResult<GetKSYunBucketBean.Response>?) { override fun onSuccess(result: HttpResult<AuthAuthenticationBean.Response?>?) {
apiCallback.getKSYunBucketSuccess(result?.result) apiCallback.authAuthenticationSuccess(result?.result)
} }
override fun onFailer(result: HttpResult<GetKSYunBucketBean.Response>?) { override fun onFailer(result: HttpResult<AuthAuthenticationBean.Response?>?) {
apiCallback.getKSYunBucketFailure(result?.status) apiCallback.authAuthenticationFailure(result?.reason)
} }
}) })
} }
// 获取金山云Bucket // 106 获取生活号列表接口
fun businessLicenseOCR(apiCallback: IBusinessLicenseOCRCallback, requestParams: HashMap<String, String?>) { fun getLifeAccountList(apiCallback: IGetLifeAccountListCallback) {
val timeStamp = System.currentTimeMillis() val timeStamp = System.currentTimeMillis()
val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp) val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp)
val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp) val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(HashMap(), timeStamp)
ServiceFactory.getInstance().createService(CommonService::class.java) ServiceFactory.getInstance().createService(CommonService::class.java)
.businessLicenseOCR(publicParamsMap, privateParamsMap) .getAccountList(publicParamsMap, privateParamsMap)
.compose(TransformUtil.defaultSchedulers()) .compose(TransformUtil.defaultSchedulers())
.subscribe(object : HttpResultSubscriber<BusinessLicenseOCRBean.Response>() { .subscribe(object : HttpResultSubscriber<ArrayList<LifeAccountItemBean.Response>?>() {
override fun onSuccess(result: HttpResult<BusinessLicenseOCRBean.Response>?) { override fun onSuccess(result: HttpResult<ArrayList<LifeAccountItemBean.Response>?>?) {
apiCallback.businessLicenseOCRSuccess(result?.result) apiCallback.getLifeAccountListSuccess(result?.result)
} }
override fun onFailer(result: HttpResult<BusinessLicenseOCRBean.Response>?) { override fun onFailer(result: HttpResult<ArrayList<LifeAccountItemBean.Response>?>?) {
apiCallback.businessLicenseOCRFailure(result?.status) apiCallback.getLifeAccountListFailure(result?.reason)
} }
}) })
} }
// 文件上传 // 201 身份证OCR接口
fun uploadFile(apiCallback: IUploadFileCallback, requestParams: MultipartBody.Part) { fun getIDCardOCR(apiCallback: IGetIDCardOCRCallback, requestParams: HashMap<String, String?>) {
val timeStamp = System.currentTimeMillis() val timeStamp = System.currentTimeMillis()
val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp) val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp)
val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp)
ServiceFactory.getInstance().createService(CommonService::class.java) ServiceFactory.getInstance().createService(CommonService::class.java)
.uploadFile(publicParamsMap, requestParams) .getIDCardOCR(publicParamsMap, privateParamsMap)
.compose(TransformUtil.defaultSchedulers()) .compose(TransformUtil.defaultSchedulers())
.subscribe(object : HttpResultSubscriber<Any?>() { .subscribe(object : HttpResultSubscriber<GetIDCardOCRBean.Response>() {
override fun onSuccess(result: HttpResult<Any?>?) { override fun onSuccess(result: HttpResult<GetIDCardOCRBean.Response>?) {
apiCallback.uploadFileCallBack(result) apiCallback.getIDCardOCRSuccess(result?.result)
} }
override fun onFailer(result: HttpResult<Any?>?) { override fun onFailer(result: HttpResult<GetIDCardOCRBean.Response>?) {
apiCallback.uploadFileCallBack(result) apiCallback.getIDCardOCRFailure(result?.reason)
} }
}) })
} }
// pushToken绑定接口 // 202 获取人脸检测token接口
fun pushTokenAndroid(requestParams: HashMap<String, String?>) { fun authPersonalGetToken(apiCallback: AuthPersonalGetTokenCallback, requestParams: HashMap<String, String?>) {
val timeStamp = System.currentTimeMillis() val timeStamp = System.currentTimeMillis()
val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp) val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp)
val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp) val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp)
ServiceFactory.getInstance().createService(CommonService::class.java) ServiceFactory.getInstance().createService(CommonService::class.java)
.pushTokenAndroid(publicParamsMap, privateParamsMap) .authPersonalGetToken(publicParamsMap, privateParamsMap)
.compose(TransformUtil.defaultSchedulers()) .compose(TransformUtil.defaultSchedulers())
.subscribe(object : HttpResultSubscriber<Any?>() { .subscribe(object : HttpResultSubscriber<AuthPersonalGetTokenBean.Response?>() {
override fun onSuccess(result: HttpResult<Any?>?) { override fun onSuccess(result: HttpResult<AuthPersonalGetTokenBean.Response?>?) {
apiCallback.getTokenSuccess(result)
} }
override fun onFailer(result: HttpResult<Any?>?) { override fun onFailer(result: HttpResult<AuthPersonalGetTokenBean.Response?>?) {
} }
}) })
} }
// 101 身份信息校验接口 // 203 人脸检测接口
fun authPersonalCheck(apiCallback: IAuthPersonalCheckCallback, requestParams: HashMap<String, String?>) { fun identifyIdOcrVerify(apiCallback: IdentifyIdOcrVerifyCallback, requestParams: HashMap<String, String?>) {
val timeStamp = System.currentTimeMillis() val timeStamp = System.currentTimeMillis()
val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp) val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp)
val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp) val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp)
ServiceFactory.getInstance().createService(CommonService::class.java) ServiceFactory.getInstance().createService(CommonService::class.java)
.authPersonalCheck(publicParamsMap, privateParamsMap) .identifyIdOcrVerify(publicParamsMap, privateParamsMap)
.compose(TransformUtil.defaultSchedulers()) .compose(TransformUtil.defaultSchedulers())
.subscribe(object : HttpResultSubscriber<Any>() { .subscribe(object : HttpResultSubscriber<IdentifyIdOcrVerifyBean.Response?>() {
override fun onSuccess(result: HttpResult<Any>?) { override fun onSuccess(result: HttpResult<IdentifyIdOcrVerifyBean.Response?>?) {
apiCallback.authPersonCheckSuccess() apiCallback.identifyIdOcrVerifySuccess(result)
} }
override fun onFailer(result: HttpResult<Any>?) { override fun onFailer(result: HttpResult<IdentifyIdOcrVerifyBean.Response?>?) {
apiCallback.authPersonCheckFailure(result?.reason) apiCallback.identifyIdOcrVerifyFailure(result)
} }
}) })
} }
// 102 活体识别成功后回调接口 // 204 营业执照OCR接口
fun authLiveIdentity(apiCallback: IAuthLiveIdentityCallback) { fun businessLicenseOCR(apiCallback: IBusinessLicenseOCRCallback, requestParams: HashMap<String, String?>) {
val timeStamp = System.currentTimeMillis() val timeStamp = System.currentTimeMillis()
val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp) val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp)
val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(HashMap(), timeStamp) val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp)
ServiceFactory.getInstance().createService(CommonService::class.java) ServiceFactory.getInstance().createService(CommonService::class.java)
.authLiveIdentity(publicParamsMap, privateParamsMap) .businessLicenseOCR(publicParamsMap, privateParamsMap)
.compose(TransformUtil.defaultSchedulers()) .compose(TransformUtil.defaultSchedulers())
.subscribe(object : HttpResultSubscriber<Any?>() { .subscribe(object : HttpResultSubscriber<BusinessLicenseOCRBean.Response>() {
override fun onSuccess(result: HttpResult<Any?>?) { override fun onSuccess(result: HttpResult<BusinessLicenseOCRBean.Response>?) {
apiCallback.authLiveIdentitySuccess() apiCallback.businessLicenseOCRSuccess(result?.result)
} }
override fun onFailer(result: HttpResult<Any?>?) { override fun onFailer(result: HttpResult<BusinessLicenseOCRBean.Response>?) {
apiCallback.authLiveIdentityFailure(result?.reason) apiCallback.businessLicenseOCRFailure(result?.reason)
} }
}) })
} }
// 103 认证完成后创建生活号 // 301 获取金山云token接口
fun authComplete(apiCallbackPersonal: IAuthPersonalCompleteCallback, requestParams: HashMap<String, String?>) { fun getKSYunToken(requestParams: HashMap<String, String?>): HttpResult<GetKSYunTokenBean.Response>? {
val timeStamp = System.currentTimeMillis() val timeStamp = System.currentTimeMillis()
val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp) val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp)
val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp) val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp)
ServiceFactory.getInstance().createService(CommonService::class.java) val res: HttpResult<Any?>? = ServiceFactory.getInstance().createService(CommonService::class.java)
.authComplete(publicParamsMap, privateParamsMap) .getKSYunToken(publicParamsMap, privateParamsMap)
.compose(TransformUtil.defaultSchedulers()) .execute().body()
.subscribe(object : HttpResultSubscriber<AuthPersonalCompleteBean.Response?>() { if (res?.code == 0) {
override fun onSuccess(result: HttpResult<AuthPersonalCompleteBean.Response?>?) { return HttpParamsUtils.rsaDecryptResult(res, object : TypeToken<GetKSYunTokenBean.Response>() {}.type)
apiCallbackPersonal.authPersonalCompleteSuccess(result?.result) } else {
} val decodeResult = HttpResult<GetKSYunTokenBean.Response>()
decodeResult.code = res?.code!!
override fun onFailer(result: HttpResult<AuthPersonalCompleteBean.Response?>?) { decodeResult.reason = res.reason
apiCallbackPersonal.authPersonalCompleteFailure(result?.reason) decodeResult.status = res.status
} ToastUtil.showToast(YdBaseApplication.context, res.reason)
}) }
return null
} }
// 104 检测是否可以个人认证,返回认证信息 // 302 获取金山云ObjectId和Bucket接口
fun authAuthentication(apiCallback: IAuthAuthenticationCallback) { fun getKSYunObjectId(apiCallback: IGetKSYunObjectIdCallback, requestParams: HashMap<String, String?>) {
val timeStamp = System.currentTimeMillis() val timeStamp = System.currentTimeMillis()
val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp) val publicParamsMap = HttpParamsUtils.getPublicParamsMap(timeStamp)
val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(HashMap(), timeStamp) val privateParamsMap = HttpParamsUtils.getPrivateParamsMap(requestParams, timeStamp)
ServiceFactory.getInstance().createService(CommonService::class.java) ServiceFactory.getInstance().createService(CommonService::class.java)
.authAuthentication(publicParamsMap, privateParamsMap) .getKSYunObjectId(publicParamsMap, privateParamsMap)
.compose(TransformUtil.defaultSchedulers()) .compose(TransformUtil.defaultSchedulers())
.subscribe(object : HttpResultSubscriber<AuthAuthenticationBean.Response?>() { .subscribe(object : HttpResultSubscriber<GetKSYunObjectIdBean.Response>() {
override fun onSuccess(result: HttpResult<AuthAuthenticationBean.Response?>?) { override fun onSuccess(result: HttpResult<GetKSYunObjectIdBean.Response>?) {
apiCallback.authAuthenticationSuccess(result?.result) apiCallback.getKSYunObjectIdSuccess(result?.result)
} }
override fun onFailer(result: HttpResult<AuthAuthenticationBean.Response?>?) { override fun onFailer(result: HttpResult<GetKSYunObjectIdBean.Response>?) {
apiCallback.authAuthenticationFailure(result?.reason) apiCallback.getKSYunObjectIdFailure(result?.reason)
} }
}) })
} }
......
...@@ -44,12 +44,6 @@ interface CommonService { ...@@ -44,12 +44,6 @@ interface CommonService {
@QueryMap requestParams: Map<String, String?> @QueryMap requestParams: Map<String, String?>
): Observable<HttpResult<Any?>> ): Observable<HttpResult<Any?>>
@GET(URLs.getKSYunBucket)
fun getKSYunBucket(
@QueryMap commonParams: Map<String, String>,
@QueryMap requestParams: Map<String, String?>
): Observable<HttpResult<Any?>>
@Headers("Content-Type: application/json") @Headers("Content-Type: application/json")
@POST(URLs.businessLicenseOCR) @POST(URLs.businessLicenseOCR)
fun businessLicenseOCR( fun businessLicenseOCR(
......
package com.yidian.shenghuoquan.newscontent.http.httpbean
/**
* author: yinjiacheng
* date: 5/23/21 12:13 PM
* description: 获取金山云Bucket
*/
class GetKSYunBucketBean {
data class Response(val bucket: String)
}
\ No newline at end of file
package com.yidian.shenghuoquan.newscontent.http.httpbean
/**
* author: yinjiacheng
* date: 5/23/21 12:18 PM
* description: 获取金山云Bucket
*/
interface IGetKSYunBucketCallback {
fun getKSYunBucketSuccess(result: GetKSYunBucketBean.Response?)
fun getKSYunBucketFailure(message: String?)
}
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment