package com.ld.igds.n2.manager;

import com.ld.igds.common.CoreDeviceService;
import com.ld.igds.constant.DeviceStatus;
import com.ld.igds.constant.DeviceType;
import com.ld.igds.io.RemoteControlService;
import com.ld.igds.io.request.DeviceControlRequest;
import com.ld.igds.io.request.ExeDevice;
import com.ld.igds.models.Device;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;


/**
 * 自动气调模式执行，首先针对双通道设备，先开口，第二次执行开风机
 */
public class N2AutoControlTask implements Callable<String> {

    private DeviceControlRequest request;

    private CoreDeviceService coreDeviceService;

    RemoteControlService remoteControlService;


    public void setRequest(DeviceControlRequest request) {
        this.request = request;
    }

    public void setRemoteControlService(RemoteControlService remoteControlService) {
        this.remoteControlService = remoteControlService;
    }

    public void setCoreDeviceService(CoreDeviceService coreDeviceService) {
        this.coreDeviceService = coreDeviceService;
    }

    public N2AutoControlTask() {
        super();
    }

    public N2AutoControlTask(DeviceControlRequest request, CoreDeviceService coreDeviceService, RemoteControlService remoteControlService) {
        this.request = request;
        this.coreDeviceService = coreDeviceService;
        this.remoteControlService = remoteControlService;
    }


    @Override
    public String call() throws Exception {


        //第一輪執行
        List<ExeDevice> listNext = exeCall(1, request.getDeviceList());


        //第二轮执行
        Thread.sleep(5 * 1000);
        if (null == listNext || listNext.isEmpty()) {
            exeCall(2, request.getDeviceList());
        }

        return "SUCCESS";
    }

    private List<ExeDevice> exeCall(int index, List<ExeDevice> listExeDevice) throws Exception {


        if (listExeDevice.isEmpty()) return null;


        List<ExeDevice> result = new ArrayList<>();

        //设备状态查询
        remoteControlService.queryStatus(request);

        Thread.sleep(5 * 1000);

        //取设备状态
        List<Device> listDevice = coreDeviceService.getCacheDeviceBySerId(request.getCompanyId(), request.getSerId());

        //第一轮执行
        String curStatus;
        for (ExeDevice device : listExeDevice) {

            if (DeviceStatus.W_OPEN.getCode().equals(device.getTargetStatus())) {
                device.setPassCode(Integer.valueOf(device.getLink()));
                todoControl(device);

                continue;
            }

            if (DeviceStatus.W_CLOSE.getCode().equals(device.getTargetStatus())) {
                curStatus = this.getCurDeviceStatus(device.getId(), listDevice);
                if (DeviceStatus.F_OPEN.getCode().equals(curStatus)) {
                    //第一轮执行-关风机
                    device.setTargetStatus(DeviceStatus.F_CLOSE.getCode());
                    todoControl(device);

                    //第二次执行关闭窗户
                    device.setTargetStatus(DeviceStatus.W_CLOSE.getCode());
                    device.setPassCode(Integer.valueOf(device.getLink()));
                    result.add(device);

                } else {
                    device.setPassCode(Integer.valueOf(device.getLink()));
                    todoControl(device);
                }

                continue;
            }

            if (DeviceStatus.F_OPEN.getCode().equals(device.getTargetStatus())) {
                if (DeviceType.TYPE_02.getCode().equals(device.getType()) || DeviceType.TYPE_0C.getCode().equals(device.getType())) {
                    curStatus = this.getCurDeviceStatus(device.getId(), listDevice);
                    if (DeviceStatus.W_CLOSE.getCode().equals(curStatus)) {

                        result.add(device);

                        //第一轮执行-开窗
                        device.setPassCode(Integer.valueOf(device.getLink()));
                        device.setTargetStatus(DeviceStatus.W_OPEN.getCode());
                        todoControl(device);

                    } else {
                        todoControl(device);
                    }
                } else {
                    todoControl(device);
                }

                continue;
            }

            todoControl(device);
        }

        if (index == 1) return result;

        return null;
    }

    /**
     * 执行操作
     *
     * @param device
     */
    private void todoControl(ExeDevice device) {
        List<ExeDevice> temp = new ArrayList<>();
        temp.add(device);
        request.setDeviceList(temp);
        remoteControlService.deviceControl(request);
    }


    private String getCurDeviceStatus(String deviceId, List<Device> listDevice) {
        for (Device device : listDevice) {
            if (deviceId.equals(device.getId())) return device.getStatus();
        }
        return "";
    }
}