import android.os.Build
import android.os.Environment
import android.os.Handler
import android.os.Looper
import android.text.TextUtils
import android.util.Log
import com.alibaba.ha.adapter.AliHaAdapter
import com.rrtv.action.manager.ThreadPoolManager
import com.rrtv.utils.utils.UiUtils
import java.io.ByteArrayInputStream
import java.io.File
import java.io.FileOutputStream
import java.io.IOException
import java.lang.reflect.Field
import java.text.DateFormat
import java.text.SimpleDateFormat
import java.util.*


/**
 * Java Crash 默认处理
 */
class CrashHandler : Thread.UncaughtExceptionHandler {

    private var isDebug = false
    private var isMainProcess = false

    private var sActivityKiller: IActivityKiller? = null

    companion object {
        private const val TAG = "CrashHandler"
        private var instance = CrashHandler()

        @Volatile
        @JvmStatic
        private var hasInit = false


        /**
         * 初始化
         *
         * 在 @link Application#onCreate() 方法中 install()
         *
         * @param isDebug 是否debug模式 BuildConfig.DEBUG
         * @param isMainProcess  是否是主进程 android.os.Process.myPid()
         */
        @JvmStatic
        fun install(isDebug: Boolean, isMainProcess: Boolean) {
            if (!hasInit) {
                synchronized(CrashHandler::class.java) {
                    if (!hasInit) {
                        Log.d(TAG, "install: isDebug = $isDebug, mainPid = $isMainProcess")
                        hasInit = true
                        instance.setup(isDebug, isMainProcess)
                        Log.d(TAG, "install success.")
                    }
                }
            }
        }
    }


    private fun setup(isDebug: Boolean, isMainProcess: Boolean) {
        Log.d(TAG, "setup:")
        this.isDebug = isDebug
        this.isMainProcess = isMainProcess

        Thread.setDefaultUncaughtExceptionHandler(this)

        if (!isDebug && isMainProcess) {
            // release 模式防止主线程奔溃
            Handler(Looper.getMainLooper()).post {
                while (true) {
                    try {
                        Looper.loop()
                    } catch (e: Exception) {
                        handleLooperException(e)
                    }
                }
            }

            try {
                // 生命周期的 ActivityKiller
                initActivityKiller()
            } catch (e: Exception) {
                Log.e(TAG, "拦截生命周期失败", e)
            }
        }
    }

    /**
     * 替换ActivityThread.mH.mCallback，实现拦截Activity生命周期，直接忽略生命周期的异常的话会导致黑屏，目前
     * 会调用ActivityManager的finishActivity结束掉生命周期抛出异常的Activity
     */
    private fun initActivityKiller() {
        Log.d(TAG, "initActivityKiller: Build.VERSION.SDK_INT=${Build.VERSION.SDK_INT}")
        //各版本android的ActivityManager获取方式，finishActivity的参数，token(binder对象)的获取不一样
        if (Build.VERSION.SDK_INT >= 28) {
            sActivityKiller = ActivityKillerV28()
        } else if (Build.VERSION.SDK_INT >= 26) {
            sActivityKiller = ActivityKillerV26()
        } else if (Build.VERSION.SDK_INT == 25 || Build.VERSION.SDK_INT == 24) {
            sActivityKiller = ActivityKillerV24_V25()
        } else if (Build.VERSION.SDK_INT in 21..23) {
            sActivityKiller = ActivityKillerV21_V23()
        } else if (Build.VERSION.SDK_INT in 15..20) {
            sActivityKiller = ActivityKillerV15_V20()
        } else if (Build.VERSION.SDK_INT < 15) {
            sActivityKiller = ActivityKillerV15_V20()
        }
        try {
            hookMH()
            Log.e(TAG, "hookMH Success.")
        } catch (e: Throwable) {
            Log.e(TAG, "hookMH 失败: ", e)
        }
    }

    @Throws(Exception::class)
    private fun hookMH() {
        Log.d(TAG, "hookMH: ")
        val LAUNCH_ACTIVITY = 100
        val PAUSE_ACTIVITY = 101
        val PAUSE_ACTIVITY_FINISHING = 102
        val STOP_ACTIVITY_HIDE = 104
        val RESUME_ACTIVITY = 107
        val DESTROY_ACTIVITY = 109
        val NEW_INTENT = 112
        val RELAUNCH_ACTIVITY = 126
        val activityThreadClass =
        Class.forName("android.app.ActivityThread")
        val activityThread =
        activityThreadClass.getDeclaredMethod("currentActivityThread").invoke(null)
        val mhField: Field = activityThreadClass.getDeclaredField("mH")
        mhField.setAccessible(true)
        val mhHandler = mhField.get(activityThread) as Handler
        val callbackField: Field = Handler::class.java.getDeclaredField("mCallback")
        callbackField.setAccessible(true)
        callbackField.set(mhHandler, Handler.Callback { msg ->
           if (Build.VERSION.SDK_INT >= 28) { //android P 生命周期全部走这
               val EXECUTE_TRANSACTION = 159
               if (msg.what === EXECUTE_TRANSACTION) {
                   try {
                       mhHandler.handleMessage(msg)
                   } catch (throwable: Throwable) {
                       sActivityKiller?.finishLaunchActivity(msg)
                       handleLifecycleException(throwable)
                   }
                   return@Callback true
               }
               return@Callback false
           }
           when (msg.what) {
               LAUNCH_ACTIVITY -> {
                   try {
                       mhHandler.handleMessage(msg)
                   } catch (throwable: Throwable) {
                       sActivityKiller?.finishLaunchActivity(msg)
                       handleLifecycleException(throwable)
                   }
                   return@Callback true
               }
               RESUME_ACTIVITY -> {
                   try {
                       mhHandler.handleMessage(msg)
                   } catch (throwable: Throwable) {
                       sActivityKiller?.finishResumeActivity(msg)
                       handleLifecycleException(throwable)
                   }
                   return@Callback true
               }
               PAUSE_ACTIVITY_FINISHING -> {
                   try {
                       mhHandler.handleMessage(msg)
                   } catch (throwable: Throwable) {
                       sActivityKiller?.finishPauseActivity(msg)
                       handleLifecycleException(throwable)
                   }
                   return@Callback true
               }
               PAUSE_ACTIVITY -> {
                   try {
                       mhHandler.handleMessage(msg)
                   } catch (throwable: Throwable) {
                       sActivityKiller?.finishPauseActivity(msg)
                       handleLifecycleException(throwable)
                   }
                   return@Callback true
               }
               STOP_ACTIVITY_HIDE -> {
                   try {
                       mhHandler.handleMessage(msg)
                   } catch (throwable: Throwable) {
                       sActivityKiller?.finishStopActivity(msg)
                       handleLifecycleException(throwable)
                   }
                   return@Callback true
               }
               DESTROY_ACTIVITY -> {
                   try {
                       mhHandler.handleMessage(msg)
                   } catch (throwable: Throwable) {
                       handleLifecycleException(throwable)
                   }
                   return@Callback true
               }
           }
           false
          })
    }

    /**
     * 生命周期异常处理
     */
    private fun handleLifecycleException(e: Throwable) {
        Log.e(TAG, "lifecycleException: ", e)
        reportCustomThrowable(Thread.currentThread(), RuntimeException("Activity生命周期出现异常", e))
        // 给个Toast提示
        try {
            UiUtils.showToastSafe("小猿刚刚捕获了一只BUG")
        } catch (e: Exception) {
            e.printStackTrace()
        }
    }

    /**
     * 主线程Looper异常
     */
    private fun handleLooperException(e: Exception) {
        // 主线程内发生异常 主动 catch
        Log.e(TAG, "handleLooperException: ", e)
        reportCustomThrowable(Thread.currentThread(), e)
        handleMainThreadException(e)
    }


    /**
     * 本版本不处理
     *
     * view measure layout draw时抛出异常会导致Choreographer挂掉
     * 建议直接杀死app。以后的版本会只关闭黑屏的Activity
     *
     * @param e
     */
    private fun isChoreographerException(e: Throwable?): Boolean {
        val elements = e?.stackTrace ?: return false
        for (i in elements.size - 1 downTo -1 + 1) {
            if (elements.size - i > 20) {
                return false
            }
            val element = elements[i]
            if ("android.view.Choreographer" == element.className && "Choreographer.java" == element.fileName && "doFrame" == element.methodName) {
                //View 绘制流程出的问题
                return true
            }
        }
        return false
    }


    override fun uncaughtException(t: Thread, e: Throwable) {
        Log.e(TAG, "uncaughtException: ")
        if (isDebug) {
            handleDebugException(t, e)
        } else {
            handleReleaseException(t, e)
        }
    }

    /**
     * 处理 Debug 模式的异常
     */
    private fun handleDebugException(t: Thread, e: Throwable) {
        Log.e(TAG, "handleDebugException: $t", e)
        // 记录本地日志
        saveThrowableMessage(Log.getStackTraceString(e))
    }

    /**
     * 处理 !Debug 模式的异常
     */
    private fun handleReleaseException(t: Thread, e: Throwable) {
        Log.e(TAG, "handleReleaseException: $t", e)
        // 自定义 Bug 上报
        reportCustomThrowable(t, e)
        // 根据情况来处理异常
        if (isMainProcess) {
            // 为主进程
            if (Looper.myLooper() == Looper.getMainLooper()) {
                // 主线程异常处理
                handleMainThreadException(e)
            } else {
                // 非主线程
                Log.e(TAG, "子线程异常: finish.")
            }
        } else {
            // 如果是子进程发生异常 直接殺掉子進程
            Log.e(TAG, "子进程异常: killProcess.")
            android.os.Process.killProcess(android.os.Process.myPid())
        }

    }

    /**
     * 主线程异常处理
     *
     * Looper.loop & MainThreadUncaughtException
     */
    private fun handleMainThreadException(e: Throwable) {
        Log.e(TAG, "handleMainThreadException: ")
        try {
            // 主线程
            when (e) {
                is IllegalArgumentException,
                is IllegalStateException,
                is IndexOutOfBoundsException,
                is UnsupportedOperationException,
                is ArithmeticException,
                is NumberFormatException,
                is NullPointerException,
                is ClassCastException,
                is AssertionError,
                is NoSuchElementException -> {
                    Log.e(TAG, "主线程异常: handle finish.")
                    if (isChoreographerException(e)) {
                        UiUtils.showToastSafe("界面刷新出了个小问题")
                    }
                }
                else -> {
                    Log.e(TAG, "主线程未知异常：System exit.")
                    // 这里也可以只给个提示，反正不会程序不会奔溃
                    android.os.Process.killProcess(android.os.Process.myPid())
                    System.exit(0)
                }
            }
        } catch (e: Exception) {
            e.printStackTrace()
        }

    }

    private val logFilePath = Environment.getExternalStorageDirectory().toString() +
    File.separator + "Example" +
    File.separator + "CrashLog"

    private fun saveThrowableMessage(errorMessage: String) {
        if (TextUtils.isEmpty(errorMessage)) {
            return
        }
        val file = File(logFilePath)
        if (file.exists() && file.isDirectory) {
            // fall through
        } else {
            file.mkdirs()
        }
        writeToFile(errorMessage, file)
    }

    private val formatter: DateFormat = SimpleDateFormat("yyyy-MM-dd-HH-mm-ss", Locale.CHINA)

    private fun writeToFile(errorMessage: String, file: File) {
        ThreadPoolManager.getShortPool()?.execute {
            var outputStream: FileOutputStream? = null
            try {
                val timestamp = System.currentTimeMillis()
                val time = formatter.format(Date())
                val fileName = "crash-$time-$timestamp"
                val inputStream = ByteArrayInputStream(errorMessage.toByteArray())
                outputStream = FileOutputStream(File(file, "$fileName.txt"))
                var len: Int
                val bytes = ByteArray(1024)
                while (inputStream.read(bytes).also { len = it } != -1) {
                    outputStream.write(bytes, 0, len)
                }
                outputStream.flush()
                Log.e(TAG, "异常奔溃日志成功写入本地文件：${file.absolutePath}")
            } catch (e: Exception) {
                Log.e(TAG, "异常奔溃日志写入本地文件失败: ", e)
            } finally {
                if (outputStream != null) {
                    try {
                        outputStream.close()
                    } catch (e: IOException) {
                        // nothing
                    }
                }
            }
        }
    }

    /**
     * 自定义 Bug 上报
     */
    private fun reportCustomThrowable(t: Thread, e: Throwable) {
        Log.e(TAG, "reportCustomThrowable: ")
        try {
            AliHaAdapter.getInstance().reportCustomError(e) //配置项：自定义错误
        } catch (ex: Exception) {
            Log.e(TAG, "上报自定义异常Error: ", ex)
        }
    }
}

smartRefreshLayout.setEnableScrollContentWhenLoaded(false)

import com.google.gson.Gson
import com.google.gson.JsonSyntaxException
import com.google.gson.TypeAdapter
import com.google.gson.reflect.TypeToken
import com.google.gson.stream.JsonReader
import com.google.gson.stream.JsonToken
import okhttp3.ResponseBody
import retrofit2.Converter
import java.lang.reflect.ParameterizedType
import java.lang.reflect.Type

class ResponseBodyConverter(val gson: Gson, val type: Type) :
    Converter<ResponseBody, BaseResponse<Any>> {
    override fun convert(value: ResponseBody): BaseResponse<Any> {
        val dataType = GenericsUtils.getParameterUpperBound(
            0,
            type as ParameterizedType
        )
        val baseResponse = BaseResponse<Any>()
        val jsonReader = JsonReader(value.charStream())
        try {
            jsonReader.beginObject()
            while (jsonReader.hasNext()) {
                val name: String = jsonReader.nextName()
                when (name) {
                    "code" -> {
                        baseResponse.code = jsonReader.nextString()
                    }
                    "msg" -> {
                        // this works, but do not do this.
                        if (jsonReader.peek() == JsonToken.NULL) {
                            jsonReader.nextNull()
                            baseResponse.msg = null
                        } else {
                            baseResponse.msg = jsonReader.nextString()
                        }
                    }
                    "data" -> {
                        val mapped: TypeAdapter<*>? = gson.getAdapter(TypeToken.get(dataType))
                        baseResponse.data = mapped?.read(jsonReader)
                    }
                    else -> {
                        jsonReader.skipValue()
                    }
                }
            }
        } catch (e: IllegalStateException) {
            throw JsonSyntaxException(e)
        } catch (e: IllegalAccessException) {
            throw AssertionError(e)
        }
        jsonReader.endObject()
        return baseResponse
    }
}

private var totalHeight: Int = 0
private var visibleHeight: Int = 0
private var screenHeight = 0

fun getViewRate(): String? =
if (totalHeight <= 0 || visibleHeight < 0) null
else "${(visibleHeight * 100 / totalHeight)}%"

private fun bindViewTreeObserver() {
    cleanCache()
    contentTv.post {
        totalHeight = contentTv.height
        screenHeight = ScreenUtils.getScreenHeight(context)
        contentVisibleRate()
    }
    contentTv.viewTreeObserver.addOnScrollChangedListener(mScrollChangeListener)
}

private fun cleanCache() {
    totalHeight = 0
    screenHeight = 0
    visibleHeight = 0
}

private val mScrollChangeListener = ViewTreeObserver.OnScrollChangedListener {
    contentVisibleRate()
}

private fun contentVisibleRate() {
    val location = IntArray(2)
    contentTv.getLocationOnScreen(location)
    visibleHeight = (screenHeight - location[1]).coerceAtLeast(visibleHeight)
    if (visibleHeight >= totalHeight) {
        visibleHeight = totalHeight
        removeOnScrollChangedListener()
    }
}

private fun removeOnScrollChangedListener() {
    mScrollChangeListener?.let {
        contentTv.viewTreeObserver.removeOnScrollChangedListener(mScrollChangeListener)
    }
}

import androidx.recyclerview.widget.GridLayoutManager
import androidx.recyclerview.widget.LinearLayoutManager
import androidx.recyclerview.widget.RecyclerView
import androidx.recyclerview.widget.StaggeredGridLayoutManager

object RecyclerViewHelper {
  /**
   * RecyclerView 注册加载更多监听
   */
  @JvmStatic
  fun addOnScrollListener(recyclerView: RecyclerView, loadMore: () -> Unit) {
    recyclerView.addOnScrollListener(object : RecyclerView.OnScrollListener() {
      override fun onScrollStateChanged(recyclerView: RecyclerView, newState: Int) {
        super.onScrollStateChanged(recyclerView, newState)
        if (newState == RecyclerView.SCROLL_STATE_IDLE) {
          val layoutManager = recyclerView.layoutManager
          if (layoutManager is LinearLayoutManager) {
            val lastPosition = layoutManager.findLastCompletelyVisibleItemPosition()
            val count = layoutManager.itemCount
            if (lastPosition >= count - 2) {
              loadMore()
              return@onScrollStateChanged
            }
          } else if (layoutManager is StaggeredGridLayoutManager) {
            val spanCount = layoutManager.spanCount
            val count = layoutManager.itemCount
            val result = IntArray(spanCount)
            layoutManager.findLastCompletelyVisibleItemPositions(result)
            for (it in result) {
              if (it >= count - spanCount - 1) {
                loadMore()
                return@onScrollStateChanged
              }
            }
          } else if (layoutManager is GridLayoutManager) {
            val spanCount = layoutManager.spanCount
            val count = layoutManager.itemCount
            val lastPosition = layoutManager.findLastCompletelyVisibleItemPosition()
            if (lastPosition >= count - spanCount - 1) {
              loadMore()
              return@onScrollStateChanged
            }

          }
        }
      }
    })
  }


  /**
     * 判断是否一屏显示
     *
     * 错误或者空了返回 false
     */
  @JvmStatic
  fun isOneScreen(recyclerView: RecyclerView?): Boolean {
    recyclerView?.let {
      val layoutManager = recyclerView.layoutManager
      if (layoutManager is LinearLayoutManager) {
        // include GridLayoutManager
        val count = layoutManager.itemCount
        return count > 0 &&
        layoutManager.findFirstCompletelyVisibleItemPosition() == 0 &&
        layoutManager.findLastCompletelyVisibleItemPosition() == count - 1
      } else if (layoutManager is StaggeredGridLayoutManager) {
        val spanCount = layoutManager.spanCount
        val count = layoutManager.itemCount
        val last = IntArray(spanCount)
        val first = IntArray(spanCount)
        layoutManager.findLastCompletelyVisibleItemPositions(last)
        layoutManager.findFirstCompletelyVisibleItemPositions(first)
        return count > 0 && first.min() == 0 && last.max() == count - 1
      }
    }

    return false
  }

  private fun IntArray.min(): Int {
    if (this.isNotEmpty()) {
      var result = this[0]
      this.forEach {
        if (result > it) result = it
      }
      return result
    }
    return -1
  }

  private fun IntArray.max(): Int {
    if (this.isNotEmpty()) {
      var result = this[0]
      this.forEach {
        if (result < it) result = it
      }
      return result
    }
    return -1
  }
}