package com.thhy.materials.modules.biz.video.service.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.thhy.general.common.BasicResult;
import com.thhy.materials.modules.biz.video.entity.TVideoNo;
import com.thhy.materials.modules.biz.video.service.VideoService;
import com.thhy.materials.modules.biz.weigh.mapper.WeighMapper;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import javax.annotation.Resource;
import java.util.List;
import java.util.Map;

@Service
public class VideoServiceImpl implements VideoService {


    @Resource
    private WeighMapper weighMapper;

    @Override
    public BasicResult videoList() {
        List<TVideoNo> tVideoNos = weighMapper.videoList();
        return BasicResult.success(tVideoNos);
    }

    @Override
    public BasicResult webVideoList(Map<String,Object> values) {
        List<TVideoNo> tVideoNos = weighMapper.webVideoList(values);
        return BasicResult.success(tVideoNos);
    }

    @Override
    public BasicResult videoListPathWX(Map<String, Object> values) {

        Integer types = Integer.valueOf(values.get("types").toString());

        if(types==1){
            //安全token
            String accessToken = anquan();
            String deviceNum = values.get("deviceNum").toString();
            String channelNo = values.get("channelNo").toString();
            RestTemplate restTemplate6 = new RestTemplate();
            HttpHeaders headers6 = new HttpHeaders();
            headers6.setContentType(MediaType.valueOf(MediaType.APPLICATION_FORM_URLENCODED_VALUE));
            HttpEntity<Map<String, Object>> mapHttpEntity6 = new HttpEntity<>(null, headers6);
            //String s6 = restTemplate.postForObject("https://open.ys7.com/api/lapp/live/address/limited?accessToken="+accessToken+"&deviceSerial="+videoNum+"&channelNo=1&expireTime=86400", mapHttpEntity6, String.class);
           //expireTime=300
            //地址过期时间：单位秒数，最大默认62208000（即720天），最小默认300（即5分钟）。非必选参数，为空时返回对应设备和通道的永久地址
            String s6 = restTemplate6.postForObject("https://open.ys7.com/api/lapp/live/address/limited?accessToken="+accessToken+"&deviceSerial="+deviceNum+"&channelNo="+channelNo, mapHttpEntity6, String.class);
            System.out.println(s6);
            JSONObject jsonObject = JSONObject.parseObject(s6);
            return BasicResult.success(jsonObject);
        }else if(types==2) {
            //现场
            //安全token
            String accessToken = xianchang();
            String deviceNum = values.get("deviceNum").toString();
            String channelNo = values.get("channelNo").toString();
            RestTemplate restTemplate6 = new RestTemplate();
            HttpHeaders headers6 = new HttpHeaders();
            headers6.setContentType(MediaType.valueOf(MediaType.APPLICATION_FORM_URLENCODED_VALUE));
            HttpEntity<Map<String, Object>> mapHttpEntity6 = new HttpEntity<>(null, headers6);
            //String s6 = restTemplate.postForObject("https://open.ys7.com/api/lapp/live/address/limited?accessToken="+accessToken+"&deviceSerial="+videoNum+"&channelNo=1&expireTime=86400", mapHttpEntity6, String.class);
            //expireTime=300
            //地址过期时间：单位秒数，最大默认62208000（即720天），最小默认300（即5分钟）。非必选参数，为空时返回对应设备和通道的永久地址
            String s6 = restTemplate6.postForObject("https://open.ys7.com/api/lapp/live/address/limited?accessToken="+accessToken+"&deviceSerial="+deviceNum+"&channelNo="+channelNo, mapHttpEntity6, String.class);
            System.out.println(s6);
            JSONObject jsonObject = JSONObject.parseObject(s6);
            return BasicResult.success(jsonObject);
        }
        return null;
    }


    @Override
    public BasicResult videoListPath(Map<String, Object> values) {

        Integer types = Integer.valueOf(values.get("types").toString());

        if(types==1){
            //安全token
            String accessToken = anquan();
           /* String deviceNum = values.get("deviceNum").toString();
            String channelNo = values.get("channelNo").toString();
            RestTemplate restTemplate6 = new RestTemplate();
            HttpHeaders headers6 = new HttpHeaders();
            headers6.setContentType(MediaType.valueOf(MediaType.APPLICATION_FORM_URLENCODED_VALUE));
            HttpEntity<Map<String, Object>> mapHttpEntity6 = new HttpEntity<>(null, headers6);
            //String s6 = restTemplate.postForObject("https://open.ys7.com/api/lapp/live/address/limited?accessToken="+accessToken+"&deviceSerial="+videoNum+"&channelNo=1&expireTime=86400", mapHttpEntity6, String.class);
           //expireTime=300
            //地址过期时间：单位秒数，最大默认62208000（即720天），最小默认300（即5分钟）。非必选参数，为空时返回对应设备和通道的永久地址
            String s6 = restTemplate6.postForObject("https://open.ys7.com/api/lapp/live/address/limited?accessToken="+accessToken+"&deviceSerial="+deviceNum+"&channelNo="+channelNo, mapHttpEntity6, String.class);
            System.out.println(s6);
            JSONObject jsonObject = JSONObject.parseObject(s6);*/
            return BasicResult.success(accessToken);
        }else if(types==2) {
            //现场
            //安全token
            String accessToken = xianchang();
//            String deviceNum = values.get("deviceNum").toString();
//            String channelNo = values.get("channelNo").toString();
//            RestTemplate restTemplate6 = new RestTemplate();
//            HttpHeaders headers6 = new HttpHeaders();
//            headers6.setContentType(MediaType.valueOf(MediaType.APPLICATION_FORM_URLENCODED_VALUE));
//            HttpEntity<Map<String, Object>> mapHttpEntity6 = new HttpEntity<>(null, headers6);
//            //String s6 = restTemplate.postForObject("https://open.ys7.com/api/lapp/live/address/limited?accessToken="+accessToken+"&deviceSerial="+videoNum+"&channelNo=1&expireTime=86400", mapHttpEntity6, String.class);
//            //expireTime=300
//            //地址过期时间：单位秒数，最大默认62208000（即720天），最小默认300（即5分钟）。非必选参数，为空时返回对应设备和通道的永久地址
//            String s6 = restTemplate6.postForObject("https://open.ys7.com/api/lapp/live/address/limited?accessToken="+accessToken+"&deviceSerial="+deviceNum+"&channelNo="+channelNo, mapHttpEntity6, String.class);
//            System.out.println(s6);
//            JSONObject jsonObject = JSONObject.parseObject(s6);
            return BasicResult.success(accessToken);
        }
        return null;
    }

    @Override
    public BasicResult videoListPage(Map<String, Object> values) {
        Integer pageSize = Integer.valueOf(values.get("pageSize").toString());
        Integer pageNum = Integer.valueOf(values.get("pageNum").toString());
        PageHelper.startPage(pageNum,pageSize);
        List<TVideoNo>  videoNos = weighMapper.videoListPage(values);
        PageInfo<TVideoNo> tVideoNoPageInfo = new PageInfo<>(videoNos);
        return BasicResult.success(tVideoNoPageInfo);
    }

    public String anquan(){
        RestTemplate restTemplate = new RestTemplate();
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.valueOf(MediaType.APPLICATION_FORM_URLENCODED_VALUE));
        HttpEntity<Map<String, Object>> mapHttpEntity = new HttpEntity<>(null, headers);
        //现场
        String s = restTemplate.postForObject("https://open.ys7.com/api/lapp/token/get?appKey=bbd3ec70de864ae89ed1591706240ef7&appSecret=198508bb0f99ee0a945839093ac869c3", mapHttpEntity, String.class);
        //安全   外边厂房
       // String s = restTemplate.postForObject("https://open.ys7.com/api/lapp/token/get?appKey=6f3dc77270d14f9b965d9530138753e8&appSecret=5fb063a890fbe80e28fbaafecf4ffa2c", mapHttpEntity, String.class);
        JSONObject jsonObject = JSONObject.parseObject(s);
        System.out.println(jsonObject);
        Object data = jsonObject.get("data");
        String s1 = JSON.toJSONString(data);
        JSONObject data1 = JSONObject.parseObject(s1);
        System.out.println(data);
        Object accessToken = data1.get("accessToken");
        return  accessToken.toString();
    }


    public String xianchang(){
        RestTemplate restTemplate = new RestTemplate();
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.valueOf(MediaType.APPLICATION_FORM_URLENCODED_VALUE));
        HttpEntity<Map<String, Object>> mapHttpEntity = new HttpEntity<>(null, headers);
        //现场
        //String s = restTemplate.postForObject("https://open.ys7.com/api/lapp/token/get?appKey=bbd3ec70de864ae89ed1591706240ef7&appSecret=198508bb0f99ee0a945839093ac869c3", mapHttpEntity, String.class);
        //安全   外边厂房
        String s = restTemplate.postForObject("https://open.ys7.com/api/lapp/token/get?appKey=6f3dc77270d14f9b965d9530138753e8&appSecret=5fb063a890fbe80e28fbaafecf4ffa2c", mapHttpEntity, String.class);
        JSONObject jsonObject = JSONObject.parseObject(s);
        System.out.println(jsonObject);
        Object data = jsonObject.get("data");
        String s1 = JSON.toJSONString(data);
        JSONObject data1 = JSONObject.parseObject(s1);
        System.out.println(data);
        Object accessToken = data1.get("accessToken");
        return  accessToken.toString();
    }


}