package com.ruoyi.admin.controller;


import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpResponse;
import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.ruoyi.admin.entity.Agreement;
import com.ruoyi.admin.entity.MasterWorker;
import com.ruoyi.admin.entity.Notices;
import com.ruoyi.admin.service.AgreementService;
import com.ruoyi.admin.service.MasterWorkerService;
import com.ruoyi.admin.vo.MonitorInfoVO;
import com.ruoyi.common.core.constant.Constants;
import com.ruoyi.common.core.domain.R;
import com.ruoyi.common.security.annotation.Logical;
import com.ruoyi.common.security.annotation.RequiresPermissions;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
import java.util.Random;

/**
 * <p>
 * 监控
 * </p>
 *
 * @author hjl
 * @since 2024-05-29
 */
@RestController
@RequestMapping("/monitor")
@Api(tags = {"大屏-监控"})
public class MonitorController {
    @Autowired
    private MasterWorkerService masterWorkerService;

    public static void main(String[] args) {
        HttpRequest post = HttpUtil.createGet("http://8.146.210.16:12056/api/v1/basic/devices?key=zT908g2j9niqrwO6ENIm5MZriXb0ZC%2Fq0hlFOWfm1Qs%3D");
        HttpResponse execute = post.execute();
        if (200 != execute.getStatus()) {
            return;
        }
        System.err.println(execute.body());
        JSONObject jsonObject = JSONObject.parseObject(execute.body());
        JSONArray data = jsonObject.getJSONArray("data");
        // 终端设备id
        List<JSONObject> strings = new ArrayList<>();
        for (Object datum : data) {
            JSONObject jsonObject1 = (JSONObject) datum;
            JSONObject jsonObject2 = new JSONObject();
            jsonObject2.put("terid", jsonObject1.getString("terid"));
            jsonObject2.put("deviceusername", jsonObject1.getString("deviceusername"));
            strings.add(jsonObject2);
        }
        System.err.println(strings);
    }

//    /**
//     * 回收员监控列表
//     */
//    @ApiOperation(value = "回收员监控列表")
//    @GetMapping(value = "/monitorList")
//    public R monitorList() {
//
//        // 获取token
//        String token = "";
//        HttpRequest post = HttpUtil.createGet("http://8.146.210.16:12056/api/v1/basic/key?username=dakaer&password=dakaer@888");
//        HttpResponse execute = post.execute();
//        if (200 != execute.getStatus()) {
//            return R.fail("获取三方监控token失败");
//        }
//        System.err.println("获取三方平台授权token响应参数" + execute.body());
//        token = JSONObject.parseObject(execute.body()).getJSONObject("data").getString("key");
//
//        // 获取司机列表
//        HttpRequest post1 = HttpUtil.createGet("http://8.146.210.16:12056/api/v1/basic/devices?key="+token);
//        HttpResponse execute1 = post1.execute();
//        if (200 != execute1.getStatus()) {
//            return R.fail("获取三方监控司机列表失败");
//        }
//        System.err.println(execute1.body());
//        JSONObject jsonObject = JSONObject.parseObject(execute1.body());
//        JSONArray data = jsonObject.getJSONArray("data");
//        // 终端设备id
//        List<JSONObject> strings = new ArrayList<>();
//        List<String> terIds = new ArrayList<>();
//        for (Object datum : data) {
//            JSONObject jsonObject1 = (JSONObject) datum;
//            JSONObject jsonObject2 = new JSONObject();
//            jsonObject2.put("terid",jsonObject1.getString("terid"));
//            jsonObject2.put("deviceusername",jsonObject1.getString("deviceusername"));
//            strings.add(jsonObject2);
//            terIds.add(jsonObject1.getString("terid"));
//        }
//        System.err.println(strings);
//        // 获取司机位置信息
//        HttpRequest post2 = HttpUtil.createPost("http://8.146.210.16:12056/api/v1/basic/gps/last");
//        JSONObject jsonObject4 = new JSONObject();
//        jsonObject4.put("key",token);
//        jsonObject4.put("terid",terIds);
//        post2.body(jsonObject4.toJSONString());
//
//        HttpResponse execute2 = post2.execute();
//        if (200 != execute2.getStatus()) {
//            return R.fail("获取三方监控司机列表失败");
//        }
//        System.err.println(execute2.body());
//        JSONObject jsonObject1 = JSONObject.parseObject(execute2.body());
//        JSONArray data2 = jsonObject1.getJSONArray("data");
//        // 终端设备id
//        List<JSONObject> strings1 = new ArrayList<>();
//        for (Object datum : data2) {
//            JSONObject jsonObject3 = (JSONObject) datum;
//            JSONObject jsonObject2 = new JSONObject();
//            jsonObject2.put("lat",jsonObject3.getString("gpslat"));
//            jsonObject2.put("lng",jsonObject3.getString("gpslng"));
//            jsonObject2.put("terid",jsonObject3.getString("terid"));
//            strings1.add(jsonObject2);
//        }
//        for (JSONObject object : strings1) {
//            String string = object.getString("terid");
//            for (JSONObject string1 : strings) {
//                if (string1.getString("terid").equals(string)){
//                    object.put("name",string1.getString("deviceusername"));
//                    break;
//                }
//            }
//        }
//        System.err.println(strings1);
//        return R.ok(strings1);
//    }
    /**
     * 回收员监控列表
     */
    @ApiOperation(value = "回收员监控详情")
    @GetMapping(value = "/monitorInfo")

    public R<MonitorInfoVO> monitorInfo(String terid) {
        MonitorInfoVO monitorInfoVO = new MonitorInfoVO();
        MasterWorker one = masterWorkerService.lambdaQuery().eq(MasterWorker::getTerminalCode, terid).last("limit 1").one();
        if (one==null){
            return R.fail("当前师傅未绑定终端编号");
        }
        // 获取token
        String token = "";
        HttpRequest post = HttpUtil.createGet("http://8.146.210.16:12056/api/v1/basic/key?username=dakaer&password=dakaer@888");
        HttpResponse execute = post.execute();
        if (200 != execute.getStatus()) {
        }
        System.err.println("获取三方平台授权token响应参数" + execute.body());
        token = JSONObject.parseObject(execute.body()).getJSONObject("data").getString("key");
        // 获取端口
        HttpRequest post9 = HttpUtil.createGet("http://8.146.210.16:12056/api/v1/basic/live/port?key="+token);
        HttpResponse execute9 = post9.execute();
        if (200 != execute9.getStatus()) {
        }
        System.err.println(execute9.body());
        JSONObject jsonObject9 = JSONObject.parseObject(execute9.body());
        JSONArray data9 = jsonObject9.getJSONArray("data");
        int i = new Random().nextInt(data9.size());
        Object o = data9.get(i);
        JSONObject temp = (JSONObject) o;
        String port = temp.getString("port");

        // 获取司机列表
        HttpRequest post2 = HttpUtil.createGet("http://8.146.210.16:12056/api/v1/basic/devices?key="+token);
        HttpResponse execute2 = post2.execute();
        if (200 != execute2.getStatus()) {
        }
        System.err.println(execute2.body());
        JSONObject jsonObject = JSONObject.parseObject(execute2.body());
        JSONArray data = jsonObject.getJSONArray("data");
        // 终端设备id
        List<JSONObject> strings = new ArrayList<>();
        List<String> terIds = new ArrayList<>();
        for (Object datum : data) {
            JSONObject jsonObject1 = (JSONObject) datum;
            JSONObject jsonObject2 = new JSONObject();
            jsonObject2.put("terid",jsonObject1.getString("terid"));
            jsonObject2.put("deviceusername",jsonObject1.getString("deviceusername"));
            jsonObject2.put("carlicence",jsonObject1.getString("carlicence"));
            strings.add(jsonObject2);
            terIds.add(jsonObject1.getString("terid"));
        }
        System.err.println(strings);
        // 获取url
        HttpRequest post1 = HttpUtil.createGet("http://8.146.210.16:12056/api/v1/basic/live/video?key="+token+"&terid="+terid+"&chl=1&audio=1&st=0&port="+port);
        HttpResponse execute1 = post1.execute();
        if (200 != execute1.getStatus()) {
        }
        System.err.println(execute1.body());
        JSONObject jsonObject3 = JSONObject.parseObject(execute1.body());
        JSONObject data3 = jsonObject3.getJSONObject("data");
        String url = data3.getString("url");
        monitorInfoVO.setUrl(url);
        monitorInfoVO.setCityName(one.getCity());
        monitorInfoVO.setName(one.getRealName());
        monitorInfoVO.setPhone(one.getPhone());
        monitorInfoVO.setProfilePicture(one.getProfilePicture());
        for (JSONObject string : strings) {
            if (string.getString("terid").equals(terid)){
                monitorInfoVO.setLicensePlateNumber(string.getString("carlicence"));
                break;
            }
        }
        return R.ok(monitorInfoVO);
    }
}