package cn.huge.module.xylink.utils;


import cn.huge.base.common.exception.MethodException;
import cn.huge.base.common.utils.HttpClientUtils;
import cn.huge.base.common.utils.JsonMapper;
import cn.huge.module.xylink.domain.dto.XylinkMeetDTO;
import cn.huge.module.xylink.domain.dto.XylinkVedioDTO;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.google.common.collect.Maps;
import com.xylink.config.SDKConfigMgr;
import com.xylink.model.LV;
import com.xylink.model.LiveVideo;
import com.xylink.model.Status;
import com.xylink.util.HttpUtil;
import com.xylink.util.Result;
import com.xylink.util.SignatureSample;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;

import java.io.IOException;
import java.util.List;
import java.util.Map;

@Slf4j
public class XylinkUtils {

	/**
	 * LOCAL_RECORD(本地小鱼录像机录制), SERVER_RECORD(会议录制), LIVE_RECORD(直播录制),
	 * SERVER_RECORD_TRANSCODING(会议录制转码中，此状态下不能播放、下载视频文件，24小时内处理完成后才可以播放、下载)
	 */
	public static String VOD_METADATA_TYPE_1 = "LOCAL_RECORD";
	public static String VOD_METADATA_TYPE_2 = "SERVER_RECORD";
	public static String VOD_METADATA_TYPE_3 = "LIVE_RECORD";
	public static String VOD_METADATA_TYPE_4 = "SERVER_RECORD_TRANSCODING";

	/**
	 * JsonMapper工具类
	 */
	private static JsonMapper jsonMapper = new JsonMapper();

	/**
	 * 签名类
	 */
	private static SignatureSample signatureSample = new SignatureSample();

	/**
	 * 小鱼相关参数
	 */
	public static String token = "964edbc78dfd8caef97acca3a7068fb0603e3e6f5dc25023c5443aaae04b9914";
	public static String enterpriseId = "9675f5cae97ca23503dd2fbc4c20ba089fecb59d";

	/**
	 * 创建会议室相关地址
	 * @return String
	 */
	private static String getCreateMeetingUrl() {
		return SDKConfigMgr.getServerHost() + "/api/rest/external/v2/create_meeting";
	}

	/**
	 * 视频链接相关地址
	 */
	private static String getPrefixUrl() {
		return SDKConfigMgr.getServerHost() + "/api/rest/external/v1/";
	}

	/**
	 * 视频地址
	 */
	private static String getVideoUrl() {
		return SDKConfigMgr.getServerHost() + "/api/rest/external/v1/vods/page";
	}

	/**
	 * 小鱼设备直播地址
	 * @return
	 */
	private static String getxyLiveUrl() {
		return SDKConfigMgr.getServerHost() + "/api/rest/external/v1/liveVideo2/enterprise/";
	}

	/**
	 * 会议直播地址
	 * @return
	 */
	private static String getLiveUrl() {
		return SDKConfigMgr.getServerHost() + "/api/rest/external/v1/liveVideo3/enterprise/";
	}

	/**
	 * 获取签名后的POST请求地址
	 * @param surl 请求url
	 * @param jsonEntity 请求参数
	 * @return String
	 */
	private static String getPostUrl(String surl, String jsonEntity){
		String signature = signatureSample.computeSignature(jsonEntity,"POST", token, surl);
		return surl + "&signature=" + signature;
	}

	/**
	 * 获取签名后的Get请求地址
	 * @param surl 请求url
	 * @return String
	 */
	private static String getGetUrl(String surl){
		String signature = signatureSample.computeSignature("","GET", token, surl);
		return surl + "&signature=" + signature;
	}

	/**
	 * 获取签名后的DELETE请求地址
	 *
	 * @param surl
	 * @return
	 * @throws Exception
	 */
	private static String getDeleteUrl(String surl){
		String signature = signatureSample.computeSignature("","DELETE",token,surl);
		return surl + "&signature=" + signature;
	}

	/**
	 * 创建云会议
	 * @param meetingName 会议名称
	 * @param controlPassword 主持密码
	 * @param password 入会密码
	 * @return JSONObject
	 */
	public static XylinkMeetDTO createMeet(String meetingName, String controlPassword, String password) {
		try{
			// 云会议室参数
			Map<String, Object> param = Maps.newHashMap();
			param.put("meetingName", meetingName);
			if (StringUtils.isNotEmpty(password)){
				param.put("password", password);
			}
			if (StringUtils.isNotEmpty(controlPassword)){
				param.put("controlPassword", controlPassword);
			}
			// 云会议室扩展配置
			Map<String, Object> config = Maps.newHashMap();
			config.put("autoRecord", true);
			config.put("onlyRecordMainImage", false);
			config.put("recordAddDeviceName", true);
			param.put("configs", config);
			String jsonStr = jsonMapper.toJson(param);
			String surl = getCreateMeetingUrl() + "?enterpriseId=" + enterpriseId;
			String url = getPostUrl(surl, jsonStr);
			String result = HttpClientUtils.httpPostRaw(url, jsonStr, null , null);
			XylinkMeetDTO xylinkMeetDTO = JSONObject.parseObject(result, XylinkMeetDTO.class);
			return xylinkMeetDTO;
		}catch (Exception e){
			log.error("utils方法[XylinkUtils.createMeet]调用异常："+e, e);
			throw new MethodException("XylinkUtils.createMeet", e);
		}
	}

	/**
	 * 根据视频会议号获取视频信息
	 * @param meetingRoomNum
	 * @return
	 * @throws Exception
	 */
	public static List<XylinkVedioDTO> getMeetingVideos(String meetingRoomNum) {
		List<XylinkVedioDTO> xylinkVedioDTOList = null;
		try{
			String surl = getPrefixUrl()  + "meetingroom/" + meetingRoomNum + "/vods?enterpriseId=" + enterpriseId;
			String url = getGetUrl(surl);
			String jsonResult = HttpClientUtils.httpGet(url, null, null);
			JSONArray jsonArray = JSONArray.parseArray(jsonResult);
			log.info("save saveVideo jsonArray {}", JSON.toJSONString(jsonArray));
			if (CollectionUtils.isNotEmpty(jsonArray)) {
				xylinkVedioDTOList = JSONObject.parseArray(jsonArray.toJSONString(), XylinkVedioDTO.class);
				for (XylinkVedioDTO xylinkVedioDTO: xylinkVedioDTOList) {
					xylinkVedioDTO.setDownloadUrl(getDownloadUrl(xylinkVedioDTO.getVodId()));
					xylinkVedioDTO.setPlayUrl(getPlayUrl(xylinkVedioDTO.getVodId()));
				}
			}
		} catch (Exception e){
			log.error("utils方法[XylinkUtils.getMeetingVideos]调用异常："+e, e);
		}
		return xylinkVedioDTOList;
	}

	/**
	 * 获取视频会议下载URL
	 * @param vodId 视频编号
	 * @return String
	 */
	public static String getDownloadUrl(String vodId) {
		try{
			String surl = getPrefixUrl()  + "vods/"+ vodId+ "/getdownloadurl?enterpriseId=" + enterpriseId;
			String url = getGetUrl(surl);
			String jsonResult = HttpClientUtils.httpGet(url, null, null);
			JSONObject data = JSONObject.parseObject(jsonResult);
			String result = data.getString("downloadUrl");
			return result;
		}catch (Exception e){
			log.error("utils方法[XylinkUtils.getDownloadUrl]调用异常："+e, e);
			throw new MethodException("XylinkUtils.getDownloadUrl", e);
		}
	}

	/**
	 * 获取视频会议播放URL
	 * @param vodId 视频编号
	 * @return String
	 */
	public static String getPlayUrl(String vodId) {
		try{
			String surl = getPrefixUrl()  + "vods/"+ vodId+ "/sharedInfo?enterpriseId=" + enterpriseId;
			String url = getGetUrl(surl);
			String jsonResult = HttpClientUtils.httpGet(url, null, null);
			JSONObject data = JSONObject.parseObject(jsonResult);
			String result = data.getString("playUrl");
			return result;
		}catch (Exception e){
			log.error("utils方法[XylinkUtils.getPlayUrl]调用异常："+e, e);
			throw new MethodException("XylinkUtils.getPlayUrl", e);
		}
	}

	/**
	 * 根据视频号删除会议视频
	 *
	 * @param vodId
	 * @return
	 * @throws Exception
	 */
	public static String deleteVideo(String vodId) throws Exception{
		try{
			String surl = getPrefixUrl()  + "vods/"+ vodId+ "?enterpriseId=" + enterpriseId;
			String url = getDeleteUrl(surl);
			String jsonResult = HttpClientUtils.httpDelete(url, null, null);
			return jsonResult;
		} catch (Exception e){
			throw new Exception(e.getMessage(), e);
		}
	}

	/**
	 * 分页查询企业某段时间的视频列表
	 * @param startTime 开始时间
	 * @param endTime 结束时间
	 * @param pageIndex 页码： 从0开始
	 * @param pageSize 每页查询数量：最大50
	 * @return
	 */
	public static String getEnterpriseVideos(long startTime, long endTime, int pageIndex, int pageSize) {
		List<XylinkVedioDTO> xylinkVedioDTOList = null;
		try{
			String surl = getVideoUrl()  + "?enterpriseId=" + enterpriseId +
					"&startTime=" + startTime + "&endTime=" + endTime +
					"&pageIndex=" + pageIndex + "&pageSize=" + pageSize;
			String url = getGetUrl(surl);
			String jsonResult = HttpClientUtils.httpGet(url, null, null);
			return jsonResult;
		} catch (Exception e){
			log.error("utils方法[XylinkUtils.getEnterpriseVideos]调用异常："+e, e);
			return null;
		}
	}

	/**
	 * 创建自定义会议
	 *
	 * @param meetingName
	 * @return
	 * @throws Exception
	 */
	public static JSONObject customMeeting(String meetingName) throws Exception{
		try{
			Map<String, Object> param = Maps.newHashMap();
			param.put("meetingName", meetingName);
			param.put("controlPassword", "12345678");

			Map<String, Object> config = Maps.newHashMap();
			config.put("autoRecord", false);
			config.put("onlyRecordMainImage", false);
			config.put("recordAddDeviceName", true);
			param.put("configs", config);
			JsonMapper jsonMapper = new JsonMapper();
			String jsonStr = jsonMapper.toJson(param);

			String surl = getCreateMeetingUrl() + "?enterpriseId=" + enterpriseId;
			String url = getPostUrl(surl, jsonStr);

			String result = HttpClientUtils.httpPostRaw(url, jsonStr, null , null);
			JSONObject jsonObject = JSONObject.parseObject(result);
			return jsonObject;
		}catch (Exception e){
			throw new Exception(e.getMessage(), e);
		}
	}

	/**
	 * 创建小鱼设备直播
	 *
	 * @param nemoNumber
	 * @param liveVideo
	 * @return
	 * @throws IOException
	 */
	public static LV newXyLiveVideo(String nemoNumber, LiveVideo liveVideo) throws IOException{
		String surl = getxyLiveUrl() + enterpriseId + "/xiaoyunumber/" + nemoNumber + "/live?enterpriseId="+enterpriseId;
		String jsonEntity = new ObjectMapper().writeValueAsString(liveVideo);
		String signature = signatureSample.computeSignature(jsonEntity,"POST",token,surl);
		surl += "&signature=" + signature;
		Result result = HttpUtil.getResponse(surl,"POST", jsonEntity, LV.class);
		return (LV)result.getData();
	}

	/**
	 * 开始/结束直播
	 * @param confNo
	 * @param confPwd
	 * @param liveId
	 * @param status
	 * @return
	 * @throws IOException
	 */
	public static Result controlLive(String confNo, String confPwd, String liveId, Status status)throws IOException{
		String surl = getLiveUrl() + enterpriseId + "/conf/" + confNo + "/live/" + liveId + "/status"
				+ "?enterpriseId="+enterpriseId + "&confPwd=" + confPwd;
		String jsonEntity = new ObjectMapper().writeValueAsString(status);
		String signature = signatureSample.computeSignature(jsonEntity,"PUT",token,surl);
		surl += "&signature=" + signature;
		return HttpUtil.getResponse(surl,"PUT", jsonEntity, null);
	}

	/**
	 * 删除小鱼设备直播
	 * @param nemoNumber
	 * @param liveId
	 * @return
	 * @throws IOException
	 */
	public static Result deleteXyLiveVideo(String nemoNumber,String liveId)throws IOException{
		String surl = getxyLiveUrl() + enterpriseId + "/xiaoyunumber/" + nemoNumber + "/live/" +liveId
				+ "?enterpriseId="+enterpriseId;
		System.out.println(surl);
		String signature = signatureSample.computeSignature("","DELETE",token,surl);
		surl += "&signature=" + signature;
		System.out.println(surl);
		return HttpUtil.getResponse(surl,"DELETE", null, null);
	}

	/**
	 * 获取小鱼设备直播视频
	 * @param nemoNumber
	 * @param liveId
	 * @return
	 * @throws IOException
	 */
	public static Result<LV> getLiveVideo(String nemoNumber,String liveId) throws IOException{
		String surl = getxyLiveUrl() + enterpriseId + "/xiaoyunumber/" + nemoNumber + "/live/" +liveId
				+ "?enterpriseId="+enterpriseId;
		String signature = signatureSample.computeSignature("","GET",token,surl);
		surl += "&signature=" + signature;
		System.out.println(surl);
		return HttpUtil.getResponse(surl,"GET", null, LV.class);
	}
}