package com.hbbh.adapter.manager.impl;

import com.alibaba.fastjson.JSON;
import com.google.common.collect.Maps;
import com.hbbh.adapter.manager.MonibucaManager;
import com.hbbh.adapter.utils.HttpClientUtil;
import com.hbbh.adapter.vo.CallResult;
import com.hbbh.adapter.vo.MessageVO;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import java.util.LinkedHashMap;
import java.util.Map;


@Service
public class MonibucaManagerImpl implements MonibucaManager {

    private static final Logger log = LoggerFactory.getLogger(Class.class);


    @Value("${monica.ip}")
    private String monicaIP;
    @Value("${monica.port}")
    private String monicaPort;


    //入参 rtsp视频流
    private String rtspDemo="rtsp://wowzaec2demo.streamlock.net/vod/mp4:BigBuckBunny_115k.mov";

    //返回结果，通过配置文件即可反推得到 前提是调用 rtsp/pull 接口成功
    private String jessibucaDemo="ws://localhost:8080/live/test.flv";

    //StreamPath 是发布流的唯一标识
    private String streamPath="live/test";


    // =========== monica监控 ===========

    /**
     * 调用Gateway API
     * 成功返回 {"code":0}
     * 失败返回 {"code":1,"msg":"publish badname"}
     * @return jessibucaDemo
     */
    @Override
    public String parseVideo() {
        String url="http://localhost:8081/rtsp/pull";
        Map<String, String> params = Maps.newLinkedHashMap();
        params.put("target",rtspDemo);
        params.put("streamPath",streamPath);

        String result = HttpClientUtil.doGet(url, params);


        Map map = JSON.parseObject(result, Map.class);
        String code = map.get("code")+"";
        String msg = map.get("msg")+"";
        if (!StringUtils.equals("0",code)){
            return "-1";
        }
        return jessibucaDemo;
    }

    /**
     *
     * @param param StreamPath 是发布流的唯一标识
     * 示例： http://localhost:8081/api/stop?stream=live/test
     */
    @Override
    public void stopStream(String param) {
        String url="http://"+monicaIP+":"+monicaPort+"/api/stop";
        Map<String, String> params = Maps.newLinkedHashMap();
        params.put("stream",param);
        String result = HttpClientUtil.doGet(url, params);
        log.info("调用 Monibuca 执行结果 ： {}",result);
    }
}