package net.mamoe.mirai.simpleloader

import com.alibaba.fastjson.JSONException
import net.mamoe.mirai.Bot
import net.mamoe.mirai.alsoLogin
import net.mamoe.mirai.event.subscribeMessages
import net.mamoe.mirai.join
import net.mamoe.mirai.message.data.AtAll
import net.sf.json.JSONObject
import java.io.BufferedReader
import java.io.IOException
import java.io.InputStreamReader
import java.net.MalformedURLException
import java.net.URL

    @Throws(JSONException::class)
    fun loadJson(url: String?): String {//创建获取api json信息方法
        val json = StringBuilder()
        try {
            val urlObject = URL(url)
            val uc = urlObject.openConnection()
            val `in` = BufferedReader(InputStreamReader(uc.getInputStream(), "utf-8"))
            var inputLine: String? = null
            while (`in`.readLine().also { inputLine = it } != null) {
                json.append(inputLine)
            }
            `in`.close()
        } catch (e: MalformedURLException) {
            e.printStackTrace()
        } catch (e: IOException) {
            e.printStackTrace()
        }
        return json.toString()
    }

    @Throws(InterruptedException::class)
    suspend fun Ask() {//创建判断是否开播方法
        //约每两分钟查询一次是否开播
        val i = 0
        while (i < i + 1) {//死循环
            val uid = "***"//主播UID（非直播间号）
            val url = "http://api.live.bilibili.com/room/v1/Room/getRoomInfoOld?mid=$uid"//直播信息api
            var json = loadJson(url)
            var jsonObject = JSONObject.fromObject(json)
            var status = jsonObject.getJSONObject("data")["liveStatus"] as Int//获取liveStatus字段，0为未开播，1为开播
            if (status >= 1) {//判断开播
                println("开播啦")//输出开播日志
                //机器人发送消息，getInstance(机器人qq账号)，getGroup(发送消息到群号)，不要删除大写L，AtAll是艾特全体成员
                Bot.getInstance(***L).getGroup(***L).sendMessage(AtAll+"开播")

                //开播后判断是否下播，约每二十分钟判断一次
                val j = 0
                while (j < j + 1) {//第二个死循环
                    json = loadJson(url)
                    jsonObject = JSONObject.fromObject(json)
                    status = jsonObject.getJSONObject("data")["liveStatus"] as Int
                    //判断是否在直播
                    if (status >= 1) {
                        println("直播中")
                        Thread.sleep(1200000)
                        continue//直播中则休眠二十分钟，再次判断
                    } else {
                        println("第一次检查到下播")
                        Thread.sleep(1200000)
                        json = loadJson(url)
                        jsonObject = JSONObject.fromObject(json)
                        status = jsonObject.getJSONObject("data")["liveStatus"] as Int
                        //第一次检测到下播，休眠二十分钟再次检查
                        if (status >= 1) {
                            continue
                            //没下播则继续？？？
                        } else {
                            println("第二次检查到下播")
                            Thread.sleep(1200000)
                            json = loadJson(url)
                            jsonObject = JSONObject.fromObject(json)
                            status = jsonObject.getJSONObject("data")["liveStatus"] as Int
                            //第二次检测到下播，休眠二十分钟再次检查
                            if (status >= 1) {
                                continue
                                // ？？？
                            } else {
                                println("第三次检查到下播")
                                break
                                //第三次检测到下播，退出第二个死循环，回到第一个死循环
                            }
                        }
                    }
                }
            } else {
                println("没有开播")
                Thread.sleep(120000)
                continue
                //判断没有开播，休眠两分钟后重试
            }
        }
    }

    @Throws(InterruptedException::class)
    suspend fun main(args: Array<String>) {//主程序
        val qqId = ***L //Bot的QQ号，需为Long类型，在结尾处添加大写L
        val password = "***" //Bot的密码
        val miraiBot = Bot(qqId, password).alsoLogin() //新建Bot并登录
        miraiBot.subscribeMessages{
            "测试***" reply "running"//创建测试方法，当其他账户发送"测试***"，返回"running"则表示程序正在运行
        }
        Ask()//启动直播查询
        miraiBot.join() // 等待 Bot 离线, 避免主线程退出
    }