package com.ld.igds.protocol.fzzy;

import com.ld.igds.constant.*;
import com.ld.igds.io.request.ExeDevice;
import com.ld.igds.n2.N2ModelTag;
import com.ld.igds.util.ContextUtil;
import com.ld.igds.verb.AreationModel;
import org.apache.commons.lang3.StringUtils;

import java.util.HashMap;
import java.util.Map;

/**
 * 工具类
 *
 * @author Andy
 */
public class ServerUtils {


    /**
     * 设备状态返回的结果 KEY= serId + "_STATUS_" + deviceId value = 结果状态
     */
    private static Map<String, String> contextStatusMap = new HashMap<>();


    /**
     * 设备解析后的装法存放
     *
     * @param serId
     * @param deviceId 设备通道ID
     * @param status
     */
    public static void add2StatusMap(String companyId, String serId, String deviceId, String status) {
        contextStatusMap.put(ContextUtil.buildDeviceStatusKey(companyId, serId, deviceId), status);
    }

    public static Map<String, String> getStatusMap() {
        return contextStatusMap;
    }


    public static final String MSG_BEGIN = "<FZZY>";
    public static final String MSG_END = "<END>";

    //功能码
    public static final String FUNCTION_1001 = "1001";// 控制柜请求登录平台
    public static final String FUNCTION_1003 = "1003";// 平台获取控制柜设备信息
    public static final String FUNCTION_1004 = "1004";// 控制柜向平台推送警告通知
    public static final String FUNCTION_1005 = "1005";// 控制柜主动发起心跳
    public static final String FUNCTION_1006 = "1006";// 平台透传数据
    public static final String FUNCTION_1007 = "1007";// 控制柜推送仓房状态
    public static final String FUNCTION_1008 = "1008";// 平台远程更改仓房状态
    public static final String FUNCTION_1009 = "1009";// 平台远程授权控制柜
    public static final String FUNCTION_1010 = "1010";// 平台获取控制柜仓房信息
    public static final String FUNCTION_2101 = "2101";// 平台发起粮情检测请求
    public static final String FUNCTION_2102 = "2102";// 控制柜上报粮情采集结果
    public static final String FUNCTION_2201 = "2201";// 平台发起检测请求
    public static final String FUNCTION_2202 = "2202";// 控制上报送检测进度
    public static final String FUNCTION_2203 = "2203";// 控制柜上报检测结果
    public static final String FUNCTION_2204 = "2204";// 平台中止虫害采集
    public static final String FUNCTION_2301 = "2301";// 平台发起检测请求
    public static final String FUNCTION_2302 = "2302";// 控制柜上报检测进度
    public static final String FUNCTION_2303 = "2303";// 控制柜上报检测结果
    public static final String FUNCTION_2304 = "2304";// 平台中止气体采集
    public static final String FUNCTION_3101 = "3101";// 平台远程操作设备
    public static final String FUNCTION_3102 = "3102";// 平台获取终端设备状态
    public static final String FUNCTION_3103 = "3103";// 平台紧急全关终端设备
    public static final String FUNCTION_3201 = "3201";// 平台发起自动通风
    public static final String FUNCTION_3301 = "3301";// 平台发起自动气调
    public static final String FUNCTION_3302 = "3302";// 平台远程操控制氮机
    public static final String FUNCTION_3303 = "3303";// 平台获取制氮机状态
    public static final String FUNCTION_3304 = "3304";// 平台获取仓内气压
    public static final String FUNCTION_4001 = "4001";// 平台发起能耗监测请求
    public static final String FUNCTION_5001 = "5001";// 平台远程操作空调
    public static final String FUNCTION_5002 = "5002";// 平台获取空调状态
    public static final String FUNCTION_6001 = "6001";//


    //响应码
    public static String RESP_0000 = "0000";//	表示执行成功
    public static String RESP_1000 = "1000";//	控制柜编号错误
    public static String RESP_1001 = "1001";//	终端设备不在线
    public static String RESP_1010 = "1010";//	控制柜授权到期
    public static String RESP_1011 = "1011";//	授权码无效
    public static String RESP_1012 = "1012";//	授权码已被使用
    public static String RESP_1013 = "1013";//	授权码已过期
    public static String RESP_2000 = "2000";//	签名验证失败
    public static String RESP_3000 = "3000";//	通风模式不支持
    public static String RESP_4000 = "4000";//	气调模式不支持
    public static String RESP_5000 = "5000";//	控制柜当前为手动模式，拒绝远程操作
    public static String RESP_6000 = "6000";//	采集执行失败
    public static String RESP_6001 = "6001";//	粮情采集执行中
    public static String RESP_6002 = "6002";//	气体采集执行中
    public static String RESP_6003 = "6003";//	虫害采集执行中
    public static String RESP_9999 = "9999";//	未知错误

    //仓库状态
    static String DEPOT_STATUS_1001 = "1001";//通风
    static String DEPOT_STATUS_2001 = "2001";//气调
    static String DEPOT_STATUS_3001 = "3001";//熏蒸
    static String DEPOT_STATUS_4001 = "4001";//温控
    static String DEPOT_STATUS_5001 = "5001";//维修
    static String DEPOT_STATUS_6001 = "6001";//出库
    static String DEPOT_STATUS_7001 = "7001";//入库
    static String DEPOT_STATUS_8001 = "8001";//满仓
    static String DEPOT_STATUS_9001 = "9001";//空仓

    //设备类型
    public static String DEVICE_TYPE_1 = "1";// 风窗
    public static String DEVICE_TYPE_2 = "2";// 风口
    public static String DEVICE_TYPE_3 = "3";// 轴流风机
    public static String DEVICE_TYPE_4 = "4";// 混流风机
    public static String DEVICE_TYPE_5 = "5";// 环流风机
    public static String DEVICE_TYPE_6 = "6";// 离心风机
    public static String DEVICE_TYPE_7 = "7";//加压风机
    public static String DEVICE_TYPE_8 = "8";// 电动蝶阀
    public static String DEVICE_TYPE_9 = "9";// 照明
    public static String DEVICE_TYPE_10 = "10";//门禁
    public static String DEVICE_TYPE_11 = "11";// 空调
    public static String DEVICE_TYPE_12 = "12";// 视频


    //设备状态
    public static String DEVICE_STATUS_01 = "1";// " 开(风机正转)	01
    public static String DEVICE_STATUS_02 = "2";// 关	02
    public static String DEVICE_STATUS_03 = "3";// 风机反转	03
    public static String DEVICE_STATUS_04 = "4";// 开执行中	04
    public static String DEVICE_STATUS_05 = "5";// 关执行中	05
    public static String DEVICE_STATUS_06 = "6";// 无操作	06
    public static String DEVICE_STATUS_07 = "7";// 未知状态	07

    //空调模式
    public static String TEMP_MODE_10 = "10";//通风
    public static String TEMP_MODE_11 = "11";//制冷
    public static String TEMP_MODE_20 = "20";//风速低
    public static String TEMP_MODE_21 = "21";//风速中
    public static String TEMP_MODE_22 = "22";//风速高

    //自动气调模式
    public static String AUTO_N2_10 = "10";//抽负压	10
    public static String AUTO_N2_20 = "20";//气密性检测	20
    public static String AUTO_N2_30 = "30";//正常充氮	30
    public static String AUTO_N2_31 = "31";//加压充氮	31
    public static String AUTO_N2_40 = "40";//均氮	40
    public static String AUTO_N2_50 = "50";//氮气回收	50


    //自动通风模式
    public static String AUTO_AIR_10 = "10";// 排积热通风	10
    public static String AUTO_AIR_20 = "20";//自然通风	20
    public static String AUTO_AIR_30 = "30";//保水降温通风	30
    public static String AUTO_AIR_40 = "40";//除湿通风	40
    public static String AUTO_AIR_50 = "50";//用户模式通风	50


    //仓库类型
    public static String HOUSE_TYPE_1 = "1";// 平房仓
    public static String HOUSE_TYPE_2 = "2";//浅圆仓
    public static String HOUSE_TYPE_3 = "3";//油罐仓
    public static String HOUSE_TYPE_4 = "4";//立筒仓
    public static String HOUSE_TYPE_99 = "99";//其他


    //设备位置
    public static String DEVICE_L0 = "0";// 平房仓-仓正面
    public static String DEVICE_L1 = "1";// 平房仓-仓背面
    public static String DEVICE_L2 = "2";// 筒仓-顶部
    public static String DEVICE_L3 = "3";// 筒仓-底部


    /**
     * 生成TCP连接的KEY
     *
     * @param ip
     * @param port
     * @return
     */
    public static String getServerKey(String ip, Integer port) {
        return ip + ":" + port;
    }


    /**
     * 将协议中的仓库状态转换为平台中的仓库状态
     *
     * @param status
     * @return
     */
    public static String analysisDepotStatus(String status) {
        if (null == status) return null;
        if (status.equals(DEPOT_STATUS_1001)) {
            return DepotStatus.STATUS_33.getCode();
        }
        if (status.equals(DEPOT_STATUS_2001)) {
            return DepotStatus.STATUS_31.getCode();
        }
        if (status.equals(DEPOT_STATUS_3001)) {
            return DepotStatus.STATUS_32.getCode();
        }
        if (status.equals(DEPOT_STATUS_4001)) {
            return DepotStatus.STATUS_34.getCode();
        }
        if (status.equals(DEPOT_STATUS_5001)) {
            return DepotStatus.STATUS_9.getCode();
        }
        if (status.equals(DEPOT_STATUS_6001)) {
            return DepotStatus.STATUS_4.getCode();
        }
        if (status.equals(DEPOT_STATUS_7001)) {
            return DepotStatus.STATUS_2.getCode();
        }
        if (status.equals(DEPOT_STATUS_8001)) {
            return DepotStatus.STATUS_3.getCode();
        }
        return DepotStatus.STATUS_1.getCode();
    }

    public static String getDepotSendStatus(String status) {
        if (status.equals(DepotStatus.STATUS_33.getCode())) {
            return DEPOT_STATUS_1001;
        }
        if (status.equals(DepotStatus.STATUS_31.getCode())) {
            return DEPOT_STATUS_2001;
        }
        if (status.equals(DepotStatus.STATUS_32.getCode())) {
            return DEPOT_STATUS_3001;
        }
        if (status.equals(DepotStatus.STATUS_34.getCode())) {
            return DEPOT_STATUS_4001;
        }
        if (status.equals(DepotStatus.STATUS_9.getCode())) {
            return DEPOT_STATUS_5001;
        }
        if (status.equals(DepotStatus.STATUS_4.getCode())) {
            return DEPOT_STATUS_6001;
        }
        if (status.equals(DepotStatus.STATUS_2.getCode())) {
            return DEPOT_STATUS_7001;
        }
        if (status.equals(DepotStatus.STATUS_3.getCode())) {
            return DEPOT_STATUS_8001;
        }
        return DepotStatus.STATUS_1.getCode();
    }

    /**
     * 根据操作模式，返回空调模式
     *
     * @param mode
     * @return
     */
    public static String getTempMode(String mode) {
        if (mode.equals("01")) {
            return TEMP_MODE_11;
        }
        if (mode.equals("02")) {
            return TEMP_MODE_10;
        }
        return TEMP_MODE_11;
    }

    /**
     * 根据操作的设备，返回需要发送的设备状态
     *
     * @param exeDevice
     * @return
     */
    public static String getDeviceSendStatus(ExeDevice exeDevice) {
        if (DeviceStatus.OPEN.getCode().equals(exeDevice.getTargetStatus())) return DEVICE_STATUS_01;
        if (DeviceStatus.CLOSE.getCode().equals(exeDevice.getTargetStatus())) return DEVICE_STATUS_02;

        if (DeviceStatus.W_OPEN.getCode().equals(exeDevice.getTargetStatus())) return DEVICE_STATUS_01;
        if (DeviceStatus.W_CLOSE.getCode().equals(exeDevice.getTargetStatus())) return DEVICE_STATUS_02;

        if (DeviceStatus.F_OPEN.getCode().equals(exeDevice.getTargetStatus())) return DEVICE_STATUS_01;
        if (DeviceStatus.F_CLOSE.getCode().equals(exeDevice.getTargetStatus())) return DEVICE_STATUS_02;
        if (DeviceStatus.F_OPEN_F.getCode().equals(exeDevice.getTargetStatus())) return DEVICE_STATUS_03;

        return DEVICE_STATUS_06;
    }

    public static String analysisDeviceStatus(String deviceId, String status) {

        if (DEVICE_STATUS_01.equals(status)) return DeviceStatus.OPEN.getCode();
        if (DEVICE_STATUS_02.equals(status)) return DeviceStatus.CLOSE.getCode();
        if (DEVICE_STATUS_03.equals(status)) return DeviceStatus.F_OPEN_F.getCode();
        if (DEVICE_STATUS_04.equals(status)) return DeviceStatus.OPEN.getCode();
        if (DEVICE_STATUS_05.equals(status)) return DeviceStatus.CLOSE.getCode();
        if (DEVICE_STATUS_06.equals(status)) return DeviceStatus.ZERO.getCode();

        return DeviceStatus.ERROR.getCode();
    }


    /**
     * 根据平台自动标签获取 终端执行标签
     *
     * @param modeTag
     * @return
     */
    public static String getSendAutoAir(String modeTag) {
        if (AreationModel.MODEL_01.getCode().equals(modeTag)) return AUTO_AIR_30;
        if (AreationModel.MODEL_02.getCode().equals(modeTag)) return AUTO_AIR_20;
        if (AreationModel.MODEL_03.getCode().equals(modeTag)) return AUTO_AIR_30;
        if (AreationModel.MODEL_04.getCode().equals(modeTag)) return AUTO_AIR_40;
        if (AreationModel.MODEL_05.getCode().equals(modeTag)) return AUTO_AIR_10;

        return AUTO_AIR_50;
    }

    /**
     * 解析设备位置
     *
     * @param pos
     * @return
     */
    public static String analysisLocation(String pos, String name) {
        if (StringUtils.isEmpty(pos)) {

            if (name.indexOf("仓内") >= 0) return DeviceLocation.L_05.getCode();

            if (name.indexOf("仓外") >= 0) return DeviceLocation.L_01.getCode();

        } else {

            if (DEVICE_L0.equals(pos)) return DeviceLocation.L_01.getCode();
            if (DEVICE_L1.equals(pos)) return DeviceLocation.L_02.getCode();

            if (DEVICE_L2.equals(pos)) return DeviceLocation.L_01.getCode();
            if (DEVICE_L3.equals(pos)) return DeviceLocation.L_02.getCode();

        }
        return null;
    }

    public static String analysisDepotType(String houseType) {
        if (StringUtils.isEmpty(houseType)) return DepotType.TYPE_99.getCode();
        if (HOUSE_TYPE_1.equals(houseType)) return DepotType.TYPE_01.getCode();
        if (HOUSE_TYPE_2.equals(houseType)) return DepotType.TYPE_02.getCode();
        if (HOUSE_TYPE_3.equals(houseType)) return DepotType.TYPE_03.getCode();
        if (HOUSE_TYPE_3.equals(houseType)) return DepotType.TYPE_04.getCode();
        return DepotType.TYPE_99.getCode();
    }

    /**
     * 设备状态解析
     *
     * @param type
     * @return
     * @fanTag 是否有风机
     */
    public static String analysisDeviceType(String type, boolean fanTag) {
        if (StringUtils.isEmpty(type)) return null;

        //如果有风机
        if (fanTag) {
            if (DEVICE_TYPE_1.equals(type)) return DeviceType.TYPE_02.getCode();
            if (DEVICE_TYPE_2.equals(type)) return DeviceType.TYPE_0C.getCode();
        }

        if (DEVICE_TYPE_1.equals(type)) return DeviceType.TYPE_01.getCode();
        if (DEVICE_TYPE_2.equals(type)) return DeviceType.TYPE_0B.getCode();

        if (DEVICE_TYPE_5.equals(type)) return DeviceType.TYPE_04.getCode();

        if (DEVICE_TYPE_7.equals(type)) return DeviceType.TYPE_0D.getCode();
        if (DEVICE_TYPE_8.equals(type)) return DeviceType.TYPE_07.getCode();

        if (DEVICE_TYPE_9.equals(type)) return DeviceType.TYPE_06.getCode();
        if (DEVICE_TYPE_10.equals(type)) return DeviceType.TYPE_0E.getCode();
        if (DEVICE_TYPE_11.equals(type)) return DeviceType.TYPE_05.getCode();

        return null;
    }


    /**
     * 平台--控制柜，氮气模式编码转换
     *
     * @param mode
     * @return
     */
    public static String P2CN2Mode(String mode) {

        if (N2ModelTag.MODEL_01.getCode().equals(mode)) {
            return "10";
        }

        if (N2ModelTag.MODEL_02.getCode().equals(mode)) {
            return "50";
        }

        if (N2ModelTag.MODEL_03.getCode().equals(mode)) {
            return "30";
        }

        if (N2ModelTag.MODEL_30.getCode().equals(mode)) {
            return "20";
        }

        return "00";
    }

}