94 lines
3.9 KiB
Kotlin
94 lines
3.9 KiB
Kotlin
package com.gh.common.util
|
|
|
|
import android.content.Context
|
|
import com.gh.gamecenter.eventbus.EBCollectionChanged
|
|
import com.gh.gamecenter.manager.UserManager
|
|
import com.gh.gamecenter.common.retrofit.Response
|
|
import com.gh.gamecenter.retrofit.RetrofitManager
|
|
import io.reactivex.Observable
|
|
import io.reactivex.android.schedulers.AndroidSchedulers
|
|
import io.reactivex.schedulers.Schedulers
|
|
import okhttp3.ResponseBody
|
|
import org.greenrobot.eventbus.EventBus
|
|
import org.json.JSONObject
|
|
import retrofit2.HttpException
|
|
|
|
/**
|
|
* Created by khy on 26/07/17.
|
|
*/
|
|
object CollectionUtils {
|
|
|
|
enum class CollectionType {
|
|
toolkit, article, answer, communityArticle
|
|
}
|
|
|
|
fun postCollection(context: Context, content: String, type: CollectionType, listener: OnCollectionListener) {
|
|
|
|
val postCollection = when (type) {
|
|
CollectionType.article -> RetrofitManager.getInstance().getApi().postCollectionArticle(UserManager.getInstance().userId, content)
|
|
CollectionType.toolkit -> RetrofitManager.getInstance().getApi().postCollectionTools(UserManager.getInstance().userId, content)
|
|
CollectionType.answer -> RetrofitManager.getInstance().getApi().postCollectionAnswer(UserManager.getInstance().userId, content)
|
|
else -> return
|
|
}
|
|
postCollection
|
|
.subscribeOn(Schedulers.io())
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
.subscribe(object : Response<ResponseBody>() {
|
|
override fun onResponse(response: ResponseBody?) {
|
|
super.onResponse(response)
|
|
listener.onSuccess()
|
|
EventBus.getDefault().post(EBCollectionChanged(content, true, type))
|
|
}
|
|
|
|
override fun onFailure(e: HttpException?) {
|
|
super.onFailure(e)
|
|
if (e != null) {
|
|
try {
|
|
val string = e.response()?.errorBody()?.string()
|
|
val errorBody = JSONObject(string)
|
|
if (errorBody.getInt("code") == 403009) {
|
|
listener.onSuccess()
|
|
return
|
|
}
|
|
} catch (e: Exception) {
|
|
e.printStackTrace()
|
|
}
|
|
}
|
|
listener.onError()
|
|
}
|
|
})
|
|
}
|
|
|
|
fun deleteCollection(context: Context, id: String, type: CollectionType, listener: OnCollectionListener) {
|
|
|
|
val postCollection: Observable<ResponseBody>
|
|
when (type) {
|
|
CollectionType.article -> postCollection = RetrofitManager.getInstance().getApi().deletaCollectionArticle(UserManager.getInstance().userId, id)
|
|
CollectionType.toolkit -> postCollection = RetrofitManager.getInstance().getApi().deleteCollectionTools(UserManager.getInstance().userId, id)
|
|
CollectionType.answer -> postCollection = RetrofitManager.getInstance().getApi().deleteCollectionAnswer(UserManager.getInstance().userId, id)
|
|
else -> return
|
|
}
|
|
postCollection
|
|
.subscribeOn(Schedulers.io())
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
.subscribe(object : Response<ResponseBody>() {
|
|
override fun onResponse(response: ResponseBody?) {
|
|
super.onResponse(response)
|
|
listener.onSuccess()
|
|
EventBus.getDefault().post(EBCollectionChanged(id, false, type))
|
|
}
|
|
|
|
override fun onFailure(e: HttpException?) {
|
|
super.onFailure(e)
|
|
listener.onError()
|
|
}
|
|
})
|
|
}
|
|
|
|
|
|
interface OnCollectionListener {
|
|
fun onSuccess()
|
|
fun onError()
|
|
}
|
|
|
|
} |