/**
 * 文件名：PushMangerImpl.java 描述：实现push管理器的接口功能 修改人：eguid 修改时间：2016年6月29日 修改内容：增加管理处理器和应用名关系
 */
package cc.eguid.livepush;

import java.util.Map;
import java.util.Set;
import java.util.concurrent.ConcurrentMap;

import cc.eguid.livepush.conf.ConfUtil;
import cc.eguid.livepush.dao.HandlerDao;
import cc.eguid.livepush.dao.HandlerDaoImpl;
import cc.eguid.livepush.handler.OutHandler;
import cc.eguid.livepush.handler.PushHandler;
import cc.eguid.livepush.handler.PushHandlerImpl;


/**
 * 实现push管理器的push，delete，view服务
 * 
 * @author eguid
 * @version 2016年6月24日
 * @see PushMangerImpl
 * @since jdk1.7
 */

public class PushManagerImpl implements PushManager
{
    /**
     *配置文件
     */
    private ConfUtil confUtil = new ConfUtil();

    public PushManagerImpl()
    {
        confUtil.isHave();
    }

    /**
     * 引用push处理器
     */
    private PushHandler pusher = new PushHandlerImpl();

    /**
     * 管理处理器的主进程Process及两个输出线程的关系
     */
    private HandlerDao hd = new HandlerDaoImpl();

    public void setPusher(PushHandler pusher)
    {
        this.pusher = pusher;
    }

    public void setHd(HandlerDao hd)
    {
        this.hd = hd;
    }

    @Override
    public String push(Map<String, String> parammap)
    {
        // ffmpeg环境是否配置正确
        if (!confUtil.isHave())
        {
            return null;
        }

        // 参数是否符合要求
        if (parammap == null || parammap.isEmpty() || !parammap.containsKey("appName"))
        {
            return null;
        }
        String appName = null;
        ConcurrentMap<String, Object> resultMap = null;
        try
        {
            appName = parammap.get("appName");
            if (appName != null && "".equals(appName.trim()))
            {
                return null;
            }
            parammap.put("ffmpegPath", confUtil.getPath());
            resultMap = pusher.push(parammap);
            // 处理器和输出线程对应关系
            hd.set(appName, resultMap);
        }
        catch (Exception e)
        {
            // 暂时先写这样，后期加日志
            System.err.println("重大错误：参数不符合要求" + e.getMessage());
        }
        return appName;

    }

    @Override
    public boolean closePush(String appName)
    {
        if (hd.isHave(appName))
        {
            ConcurrentMap<String, Object> map = hd.get(appName);
            // 关闭两个线程
            ((OutHandler)map.get("error")).destroy();
            // ((OutHandler)map.get("info")).destroy();
            // 暂时先这样写，后期加日志
            System.out.println("停止命令-----end commond");
            // 关闭命令主进程
            ((Process)map.get("process")).destroy();
            // 删除处理器与线程对应关系表
            hd.delete(appName);
            return true;
        }
        return false;
    }

    @Override
    public Set<String> viewAppName()
    {
        return hd.getAllAppName();
    }

    @Override
    public boolean isHave(String appName)
    {
        hd.isHave(appName);
        return false;

    }
}