import android.text.TextUtils
import com.example.basecore.util.ThreadUtils
import com.example.smart.bean.ImageListResponse
import com.example.smart.bean.UploadResponseBean
import com.example.smart.image.ImageProvider
import com.example.smart.oss.IOssCallBack
import com.example.smart.reqeust.RetrofitClient
import com.example.smart.reqeust.RetrofitClient.okHttpClientHeader
import com.example.smart.reqeust.interceptor.HeaderInterceptor
import com.example.smart.util.StatusProvider
import com.google.gson.Gson
import com.youth.banner.util.LogUtils
import okhttp3.*
import okhttp3.MediaType.Companion.toMediaTypeOrNull
import java.io.File
import java.io.IOException


object FileUploader {


    /**
     * 单个文件
     */
    fun uploadFile(path: String, callback: ImageProvider.IImageCallback, end: () -> Unit) {

        val file = File(path)
        if (!file.exists()) {
            LogUtils.e("File does not exist")
            return
        }

        val requestBody = RequestBody.create(
            "multipart/form-data".toMediaTypeOrNull(), file
        )

        val multipartBody = MultipartBody.Builder()
            .setType(MultipartBody.FORM)
            .addFormDataPart("file", file.name, requestBody)
            .build()

        val token = StatusProvider.getToken()
        if (TextUtils.isEmpty(token)) {
            LogUtils.e("Login first")
            return
        }

        val request = Request.Builder()
            .url(RetrofitClient.serverUrl + "public/file/upload")
            .addHeader(HeaderInterceptor.authorization, "Bearer $token")
            .post(multipartBody)
            .build()


//        val client = OkHttpClient()
        val client = okHttpClientHeader()
        client.newCall(request).enqueue(object : Callback {
            override fun onFailure(call: Call, e: IOException) {
                ThreadUtils.runOnUiThread {
                    end()
                    callback.onUploadFailed()
                }
            }

            override fun onResponse(call: Call, response: Response) {
                response.body?.let {
                    val string = it.string()

                    try {
                        val bean = Gson().fromJson(string, UploadResponseBean::class.java)

                        //net img address
                        //http://47.93.28.249:8181/public/file/download/
                        //entity.name

                        ThreadUtils.runOnUiThread {
                            end()
                            if (bean.data != null) {
                                bean.data.localPath = path
                                callback.onUploadSuccess(listOf(bean.data))
                            } else {
                                callback.onUploadFailed()
                            }
                        }


                    } catch (e: Exception) {
                        ThreadUtils.runOnUiThread {
                            end()
                            callback.onUploadFailed()
                        }
                    }
                }
            }

        })
    }


    /**
     * 多个文件
     */
    fun uploadFile(
        paths: List<String>, callback: ImageProvider.IImageCallback,
        end: () -> Unit
    ) {
        val token = StatusProvider.getToken()
        if (TextUtils.isEmpty(token)) {
            LogUtils.e("Login first")
            return
        }

        val builder = MultipartBody.Builder()
            .setType(MultipartBody.FORM)

        for (path in paths) {
            if (TextUtils.isEmpty(path)) {
                LogUtils.d("file not exist = $path")
                continue
            }
            val file = File(path)
            val body = RequestBody.create("multipart/form-data".toMediaTypeOrNull(), file)
            builder.addFormDataPart("files", file.name, body)
        }
        val multipartBody = builder.build()

        val request = Request.Builder()
            .url(RetrofitClient.serverUrl + "public/file/uploadMultiple")
            .addHeader(HeaderInterceptor.authorization, "Bearer $token")
            .post(multipartBody)
            .build()


//        val client = OkHttpClient()
        val client = okHttpClientHeader()
        client.newCall(request).enqueue(object : Callback {
            override fun onFailure(call: Call, e: IOException) {
                ThreadUtils.runOnUiThread {
                    end()
                    callback.onUploadFailed()
                }
            }

            override fun onResponse(call: Call, response: Response) {
                response.body?.let {
                    val string = it.string()
                    try {
                        val bean = Gson().fromJson(string, ImageListResponse::class.java)
                        ThreadUtils.runOnUiThread {
                            end()

                            if (bean.data != null) {
                                //此处可以根据文件名称设置本地路径
                                callback.onUploadSuccess(bean.data)
                            } else {
                                callback.onUploadFailed()
                            }
                        }
                    } catch (e: Exception) {
                        ThreadUtils.runOnUiThread {
                            end()

                            callback.onUploadFailed()
                        }
                    }
                }
            }

        })
    }

}