taxiapp/app/src/main/java/cn/trans88/taxiappkotlin/net/EasyHttpTool.kt

package cn.trans88.taxiappkotlin.net

import cn.trans88.taxiappkotlin.Configurations
import cn.trans88.taxiappkotlin.TaxiApp
import cn.trans88.taxiappkotlin.ext.logd
import cn.trans88.taxiappkotlin.ext.loge
import cn.trans88.taxiappkotlin.logic.dao.AdvertiseDao
import cn.trans88.taxiappkotlin.logic.dao.DaoUtil
import cn.trans88.taxiappkotlin.logic.dao.RunTimeDataDao
import cn.trans88.taxiappkotlin.logic.model.RunTimeData
import cn.trans88.taxiappkotlin.logic.model.RuntimeJson
import cn.trans88.taxiappkotlin.logic.network.ProcessingCommands
import cn.trans88.taxiappkotlin.ui.advertise.AdvertiseType
import com.google.gson.Gson
import com.google.gson.reflect.TypeToken
import com.zhouyou.http.EasyHttp
import okhttp3.MediaType.Companion.toMediaTypeOrNull
import okhttp3.RequestBody
import com.zhouyou.http.callback.SimpleCallBack
import com.zhouyou.http.exception.ApiException
import java.util.stream.Collectors


/**
 *
 * @Author： LJH
 * @Time： 2024/2/28
 * @description：
 */
object EasyHttpTool {

    /**
     * 提交运行时长
     * @param runtimeJson String
     */
    fun sendRunTimeToServer(runtimeJson: String){
        "sendRunTimeToServer run".logd()
        val parse = ("application/json;charset=UTF-8").toMediaTypeOrNull()
        val body = RequestBody.create(parse, runtimeJson)
        EasyHttp.post(Configurations.config(TaxiApp.instance()).logServiceUrl() + "postRunningTimeLog")
            .readTimeOut(80*1000)
            .writeTimeOut(80*1000)
            .connectTimeout(80*1000)
            .headers("Authorization", "Bearer ${Configurations.config(TaxiApp.instance()).appToken()}")
            .headers("Accept-Encoding", "gzip")
            .requestBody(body)
            .retryCount(5)//本次请求重试次数
            .retryDelay(600)//本次请求重试延迟时间600ms
            .execute(object :SimpleCallBack<String>(){
                override fun onError(e: ApiException?) {
                    "上传运行时长失败：${e?.message}".loge()
                }

                override fun onSuccess(t: String?) {
                    "上传运行时长成功：${t}".loge()
                }
            })
    }

    /**
     * 提交运行时长
     */
    fun sendRunTimeToServer(){
        val sumTimeList = DaoUtil.getRunTimeDao().queryBuilder().where(
            RunTimeDataDao.Properties.IsUpload.eq(0)).list()
        "未提交的运行时长数量sumTimeList size: ${sumTimeList?.size}".logd()
        if (!sumTimeList.isNullOrEmpty()){

            for (runTimeData in sumTimeList) {
                val runtimeJson = RuntimeJson(runTimeData.cardId,runTimeData.sumRuntime,runTimeData.startRuntime)
                val runtimeJsonStr =  Gson().toJson(runtimeJson)
                "提交运行时长sendRunTimeToServer：$runtimeJsonStr".logd()
                val parse = ("application/json;charset=UTF-8").toMediaTypeOrNull()
                val body = RequestBody.create(parse, runtimeJsonStr)
                EasyHttp.post(Configurations.config(TaxiApp.instance()).logServiceUrl() + "postRunningTimeLog")
                    .readTimeOut(80*1000)
                    .writeTimeOut(80*1000)
                    .connectTimeout(80*1000)
                    .headers("Authorization", "Bearer ${Configurations.config(TaxiApp.instance()).appToken()}")
                    .headers("Accept-Encoding", "gzip")
                    .requestBody(body)
                    .retryCount(5)//本次请求重试次数
                    .retryDelay(600)//本次请求重试延迟时间600ms
                    .execute(object :SimpleCallBack<String>(){
                        override fun onError(e: ApiException?) {
                            "上传运行时长失败：${e?.message}".loge()
                        }

                        override fun onSuccess(t: String?) {
                            "上传运行时长成功：${t}".loge()
                            runTimeData.isUpload = 1
                            DaoUtil.getRunTimeDao().update(runTimeData)
                            "将提交的runTimeData标记成已上传".logd()
                        }
                    })
            }

//            val lists:List<RuntimeJson> = sumTimeList.map {
//                RuntimeJson(it.cardId,it.sumRuntime,it.startRuntime)
//            }


//            val runtimeJson =  Gson().toJson(lists)

        }

    }


    /**
     * 提交日志摘要
     * @param gpsJson String
     */
    fun sendPlayLogToServer(logJson: String){
        "提交日志摘要 $logJson".logd()
        val parse = ("application/json;charset=UTF-8").toMediaTypeOrNull()
        val body = RequestBody.create(parse, logJson)
        EasyHttp.post(Configurations.config(TaxiApp.instance()).logServiceUrl() + "postPlayerLogPlus")
            .readTimeOut(80*1000)
            .writeTimeOut(80*1000)
            .connectTimeout(80*1000)
            .headers("Authorization", "Bearer ${Configurations.config(TaxiApp.instance()).appToken()}")
            .headers("Accept-Encoding", "gzip")
            .requestBody(body)
            .retryCount(5)    //本次请求重试次数
            .retryDelay(600)  //本次请求重试延迟时间600ms
            .execute(object :SimpleCallBack<String>(){
                override fun onError(e: ApiException?) {
                    "上传日志摘要失败：${e?.message}".loge()
                }

                override fun onSuccess(t: String?) {
                    "上传日志摘要成功 $t".loge()
                }
            })
    }


    /**
     * 提交GPS数据
     * @param gpsJson String
     */
    fun sendGPSToServer(gpsJson: String){
        "提交GPS数据 $gpsJson".logd()
        val parse = ("application/json;charset=UTF-8").toMediaTypeOrNull()
        val body = RequestBody.create(parse, gpsJson)
        EasyHttp.post(Configurations.config(TaxiApp.instance()).logServiceUrl() + "postGpsLocationLog")
            .readTimeOut(80*1000)
            .writeTimeOut(80*1000)
            .connectTimeout(80*1000)
            .headers("Authorization", "Bearer ${Configurations.config(TaxiApp.instance()).appToken()}")
            .requestBody(body)
            .retryCount(5)    //本次请求重试次数
            .retryDelay(600)  //本次请求重试延迟时间600ms
            .syncRequest(true)//设置同步请求
            .execute(object :SimpleCallBack<String>(){
                override fun onError(e: ApiException?) {
                    "上传GPS数据失败：${e?.message}".loge()
                }

                override fun onSuccess(t: String?) {
                    "上传GPS数据成功 $t".loge()
                }
            })
    }

    /**
     * 上传10条播放日志
     */
    fun sendPlayLogToServer(){
        val tenPlayLogs = DaoUtil.getPlayLogger().queryBuilder().limit(10).build().list()
        val logJson = ProcessingCommands.gson.toJson(tenPlayLogs)
        "提交日志Json $logJson".logd()
        val parse = ("application/json;charset=UTF-8").toMediaTypeOrNull()
        val body = RequestBody.create(parse, logJson)
        EasyHttp.post(Configurations.config(TaxiApp.instance()).logServiceUrl() + "postPlayerLog")
            .readTimeOut(80*1000)
            .writeTimeOut(80*1000)
            .connectTimeout(80*1000)
            .headers("Authorization", "Bearer ${Configurations.config(TaxiApp.instance()).appToken()}")
            .headers("Accept-Encoding", "gzip")
            .requestBody(body)
            .retryCount(5)    //本次请求重试次数
            .retryDelay(600)  //本次请求重试延迟时间600ms
            .syncRequest(true)//设置同步请求
            .execute(object :SimpleCallBack<String>(){
                override fun onError(e: ApiException?) {
                    "上传日志失败：${e?.message}".loge()
                    try {
                        Thread.sleep(60*1000L)
                    }catch (e: Exception){
                        "Exception:${e.message}".loge()
                        e.printStackTrace()
                    }
                }

                override fun onSuccess(t: String?) {
                    "上传日志成功 $t".loge()
                    DaoUtil.getPlayLogger().deleteInTx(tenPlayLogs)
                    "删除日志成功".loge()
                }
            })
    }
}