孙向锦 / VoteC5

package com.sunvote.udptransfer;

import android.content.Context;

import com.sunvote.udptransfer.stream.SunVoteInputStream;
import com.sunvote.udptransfer.stream.SunVoteOutputStream;
import com.sunvote.udptransfer.work.BaseStationProcessWork;
import com.sunvote.udptransfer.work.RepeatMessageManager;
import com.sunvote.udptransfer.work.SDKProcessWork;
import com.sunvote.util.ByteUtils;
import com.sunvote.util.LogUtil;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

/**
 * Created by Elvis on 2017/8/8.
 * Email:Eluis@psunsky.com
 * Description:Client 配置使用
 * 1.首先开启wifi UDP的监听。
 * 2.开启SDK写入数据的监听
 * <p>
 * 外面调用只需要调用这个类，所有的开放的东西都从这个接口调用
 * <p>
 * 模块主要功能：
 * SDK -> UDPModule -> BaseStation
 * BaseStation -> UDPModule -> SDK
 * SDK->UDPModule->SDK
 * BaseStation->UDPModule -> BaseStation
 * UDPModule -> SDK
 */
public class UDPModule {

    public static final String TAG = UDPModule.class.getSimpleName();
    private SunVoteInputStream inputStream;
    private OutputStream outputStream;

    /**
     * 由外界全部配置
     *
     * @param serverIp   服务器IP地址
     * @param serverPort 服务器端口
     * @param localPort  本地端口
     */
    public UDPModule(String serverIp, int serverPort, int localPort) {
        Config.getInstance().serverIP = serverIp;
        Config.getInstance().localUDPPort = localPort;
        Config.getInstance().serverUDPPort = serverPort;
        init();
    }

    private void init() {
        SunVoteInputStream udpInputStream = new SunVoteInputStream();
        SunVoteOutputStream udpOutputStream = new SunVoteOutputStream();
        SDKProcessWork.getInstance().setInputStream(udpInputStream);
        BaseStationProcessWork.getInstance().start();
        RepeatMessageManager.getInstance().start();
        SDKProcessWork.getInstance().start();
        inputStream = udpInputStream;
        outputStream = udpOutputStream;
    }

    /**
     * 自动查找服务端IP地址
     *
     * @param serverPort 服务器端口
     * @param localPort  本地端口
     */
    public UDPModule(int serverPort, int localPort) {
        Config.getInstance().localUDPPort = localPort;
        Config.getInstance().serverUDPPort = serverPort;
        init();
    }

    /**
     * 自动查找服务端地址，并且本地和远程端口一致
     *
     * @param port 远程和与本地使用同一个端口
     */
    public UDPModule(int port) {
        Config.getInstance().localUDPPort = port;
        Config.getInstance().serverUDPPort = port;
        init();
    }

    /**
     * 无需额外配置，使用默认配置
     */
    public UDPModule() {
        init();
    }

    /**
     * 获取输入流
     * 适配前期APP使用
     * 数据转发出口
     * 后期开启直接监听接收数据包
     * @return
     */
    public SunVoteInputStream getInputStream() {
        return inputStream;
    }

    /**
     * 获取输出流
     *适配前期APP使用
     * 数据入口
     * 后期修改直接发命令包
     * @return
     */
    public OutputStream getOutputStream() {
        return outputStream;
    }

    /**
     * 释放资源
     * 最后使用完成，记得释放资源
     */
    public void release() {
        BaseStationProcessWork.getInstance().stop();
        SDKProcessWork.getInstance().stop();
        RepeatMessageManager.getInstance().stop();

        if (inputStream != null) {
            try {
                inputStream.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        if (outputStream != null) {
            try {
                outputStream.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 开启日志输出到文件
     * 可以开启线上跟踪
     */
    public void enablelogtoFile() {
        LogUtil.enableLogToFile();
    }

    /**
     * 关闭日志输出到文件
     * 关闭线上耿总
     */
    public void disableLogtoFile() {
        LogUtil.disabelLogToFile();
    }

    /**
     * 开启module中日志Studio 监视器输出
     */
    public void enableModuleLog() {
        LogUtil.enableLog();
    }

    /**
     * 关闭module中日志输出
     */
    public void disableModuleLog() {
        LogUtil.disableLog();
    }

    /**
     * 设置日志级别
     * V级别 所有日志都输出
     * D级别，debug信息输出
     * I级别，信息级别输出
     * W警告级别日志输出
     * E级别，错误级别日志输出
     *
     * @param lever
     */
    public void setDebugLever(int lever) {
        LogUtil.lever = lever;
    }


    /**
     * 设置在线检测时间
     * 重启模块后生效
     *
     * @param time
     */
    public void setOnLineCheckTime(long time) {
        if (time > 0) {
            Config.getInstance().CHECK_ON_LINE_TIME = time;
        } else {
            LogUtil.w(UDPModule.TAG, "setOnLineCheckTime time is not right.time =" + time);
        }
    }

    /**
     * 消息包未接收，重复发送的间隔时间设置
     */
    public void setRepeatCheckTime(long time) {
        if (time > 0) {
            Config.getInstance().REPEAT_INVERVAL_TIME = time;
        } else {
            LogUtil.w(UDPModule.TAG, "setRepeatCheckTime time is not right.time =" + time);
        }
    }

    public int getUdpModuleNO(){
        return ByteUtils.bytes2Int(BaseStationProcessWork.getInstance().getBaseStationInfo().getKeyId());
    }

    public void searchServarIp(){
        Config.getInstance().setCanChangerServer(true);
    }

    public void setContext(Context context){
        if(context != null){
            BaseStationProcessWork.getInstance().setContext(context);
        }
    }

}