package com.ld.igds.protocol.bhzn.verb.builder;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.ld.igds.constant.DeviceStatus;
import com.ld.igds.constant.DeviceType;
import com.ld.igds.io.request.DeviceControlRequest;
import com.ld.igds.io.request.ExeDevice;
import com.ld.igds.protocol.bhzn.verb.dto.IoMessage;
import com.ld.igds.protocol.bhzn.verb.dto.Req248;
import com.ld.igds.protocol.bhzn.verb.server.BhznVerbServerUtils;
import org.apache.commons.lang3.StringUtils;

import java.util.ArrayList;
import java.util.List;

public class ControlCommandBuilder extends CommandBuilder {

    private final static ControlCommandBuilder instance = new ControlCommandBuilder();

    private ControlCommandBuilder() {
    }

    public static ControlCommandBuilder getInstance() {
        return instance;
    }

    public IoMessage buildMessage(DeviceControlRequest request) {

        IoMessage message = new IoMessage();
        message.setIp(request.getIp());
        message.setPort(request.getPort());
        message.setBegin(BhznVerbServerUtils.MSG_START1);
        // 调整信息
        buildInfo(message, request);
        message.setSign("0000");
        message.setVersion("V1.0000000");
        message.setStNum(Integer.parseInt(request.getDepotId()));
        message.setSn(request.getSerId());
        message.setCmd(248);
        message.setResult("");
        message.setOrderId(request.getOrderId());
        message.setEnd(BhznVerbServerUtils.MSG_END);

        // 生成整体命令信息和BYte信息
        build(message);

        return message;
    }

    public void buildInfo(IoMessage message, DeviceControlRequest request) {
        Req248 info = new Req248();
        Integer[] winStr = new Integer[]{-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1};
        Integer[] fanStr = new Integer[]{-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1};
        Integer[] airStr = new Integer[]{-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1};
        Integer[] lightStr = new Integer[]{-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1};
        int winCount = 0,fanCount = 0,airCount = 0,lightCount = 0;
        List<ExeDevice> deviceList = request.getDeviceList();
        for (ExeDevice exeDevice : deviceList) {
            //窗户类型设备 包含
            if(
                    DeviceType.TYPE_0B.getCode().equals(exeDevice.getType())
                    || DeviceType.TYPE_01.getCode().equals(exeDevice.getType())
                    || DeviceType.TYPE_02.getCode().equals(exeDevice.getType())
                    || DeviceType.TYPE_0C.getCode().equals(exeDevice.getType())
            ){
                winStr[exeDevice.getPassCode()-1] = getVinStatus(exeDevice.getTargetStatus());
                if(exeDevice.getPassCode() > winCount){
                    winCount = exeDevice.getPassCode();
                }
                if(StringUtils.isNotEmpty(exeDevice.getLink()) && !"null".equals(exeDevice.getLink())){
                    fanStr[Integer.parseInt(exeDevice.getLink())-21] = getFanStatus(exeDevice.getTargetStatus());
                    if(Integer.parseInt(exeDevice.getLink()) > fanCount){
                        fanCount = exeDevice.getPassCode();
                    }
                }
            }
            //风机类型设备
            if(DeviceType.TYPE_04.getCode().equals(exeDevice.getType())
            ){
                fanStr[exeDevice.getPassCode()-21] = getFanStatus(exeDevice.getTargetStatus());
                if(exeDevice.getPassCode() > fanCount){
                    fanCount = exeDevice.getPassCode();
                }
            }
            //空调类型设备
//            if(DeviceType.TYPE_05.getCode().equals(exeDevice.getType())
//            ){
//                fanStr[exeDevice.getPassCode()-1] = getFanStatus(exeDevice.getTargetStatus());
//                if(exeDevice.getPassCode() > fanCount){
//                    fanCount = exeDevice.getPassCode();
//                }
//            }
            //照明类型设备
            if(DeviceType.TYPE_06.getCode().equals(exeDevice.getType())
            ){
                lightStr[exeDevice.getPassCode()-61] = getFanStatus(exeDevice.getTargetStatus());
                if(exeDevice.getPassCode() > lightCount){
                    lightCount = exeDevice.getPassCode();
                }
            }
        }
        info.setWinCount(winCount);
        info.setWin_Str(winStr);
        info.setFanCount(fanCount);
        info.setFan_Str(fanStr);
        info.setAirCount(airCount);
        info.setAir_Str(airStr);
        info.setLightCount(lightCount);
        info.setLight_Str(lightStr);
        message.setContentStr(JSON.toJSONString(info));
    }


    private int getVinStatus(String deviceStatus){
        if(DeviceStatus.W_OPEN.getCode().equals(deviceStatus) || DeviceStatus.OPEN.getCode().equals(deviceStatus)){
            return 1;
        }
        if(DeviceStatus.W_CLOSE.getCode().equals(deviceStatus) || DeviceStatus.CLOSE.getCode().equals(deviceStatus)){
            return 2;
        }
        if(DeviceStatus.F_CLOSE.getCode().equals(deviceStatus) ){
            return 0;
        }
        if(DeviceStatus.F_OPEN.getCode().equals(deviceStatus) ||DeviceStatus.F_OPEN_F.getCode().equals(deviceStatus) ){
            return 1;
        }
        return -1;
    }

    private int getFanStatus(String deviceStatus){
        if(DeviceStatus.F_CLOSE.getCode().equals(deviceStatus)  ){
            return 0;
        }
        if(DeviceStatus.F_OPEN.getCode().equals(deviceStatus) ||DeviceStatus.F_OPEN_F.getCode().equals(deviceStatus) ){
            return 1;
        }
        return -1;
    }

//    private int getAirStatus(ExeDevice exeDevice){
//        String s = "";
//        s += "001";
//        if(exeDevice.)
//        return 0;
//    }
}