package com.ld.igds.io.impl;

import com.ld.igds.common.CoreDeviceService;
import com.ld.igds.constant.BizType;
import com.ld.igds.constant.DeviceStatus;
import com.ld.igds.constant.DeviceType;
import com.ld.igds.io.RemoteControlService;
import com.ld.igds.io.notify.NotifyWebInvoker;
import com.ld.igds.io.constant.OrderRespEnum;
import com.ld.igds.io.constant.ProtocolEnum;
import com.ld.igds.io.request.DeviceAutoControlRequest;
import com.ld.igds.io.request.DeviceControlRequest;
import com.ld.igds.io.request.ExeDevice;
import com.ld.igds.io.request.TempControlRequest;
import com.ld.igds.io.response.DeviceControlResponse;
import com.ld.igds.models.Device;

import lombok.extern.slf4j.Slf4j;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.List;

/**
 * 默认实现类，直接返回
 */
@Slf4j
@Component
public class DefaultRemoteControlImpl implements RemoteControlService {

    @Autowired
    private NotifyWebInvoker notifyWebInvoker;

    @Autowired
    private CoreDeviceService coreDeviceService;

    @Override
    public String getProtocol() {
        return ProtocolEnum.TCP_DEFAULT.getCode();
    }

    @Override
    public DeviceControlResponse deviceControl(DeviceControlRequest request) {


        log.info("-----------------------执行默认协议-系统模拟设备操作----------------{}", request.toString());

        try {
            List<ExeDevice> listDevice = request.getDeviceList();
            String deviceType = listDevice.get(0).getType();
            String targetStatus = listDevice.get(0).getTargetStatus();

            //间隔时间定义
            long longTime = 3 * 1000, longTimeW = 5 * 1000;

            if (request.isSysExeTag()) {
                longTime = 800;
                longTimeW = 800;
            }

            if (DeviceType.TYPE_01.getCode().equals(deviceType)) {
                longTime = longTimeW;
            }

            if (DeviceType.TYPE_0B.getCode().equals(deviceType)) {
                longTime = longTimeW;
            }
            if (DeviceType.TYPE_07.getCode().equals(deviceType)) {
                longTime = longTimeW;
            }
            if (DeviceType.TYPE_09.getCode().equals(deviceType)) {
                longTime = longTimeW;
            }

            if (DeviceStatus.W_OPEN.getCode().equals(targetStatus) || DeviceStatus.W_CLOSE.getCode().equals(targetStatus)) {
                longTime = longTimeW;
            }

            Thread.sleep(longTime);

            // 模拟已经成功
            List<Device> deviceList = coreDeviceService.getCacheDeviceBySerId(request.getCompanyId(), request.getSerId());

            for (ExeDevice exDevice : listDevice) {
                Device temp;
                for (int i = 0; i < deviceList.size(); i++) {
                    temp = deviceList.get(i);
                    if (exDevice.getPassCode() == temp.getPassCode()) {
                        temp.setStatus(exDevice.getTargetStatus());
                        deviceList.set(i, temp);
                    }
                }
            }
            coreDeviceService.updateCacheDeviceBySerId(deviceList, request.getCompanyId(), request.getSerId());

            notifyWebInvoker.notifyWeb(request.getCompanyId(), OrderRespEnum.NO_PROTOCOL, BizType.SYS, "当前为演示协议解析！！");

            return new DeviceControlResponse(OrderRespEnum.ORDER_SUCCESS);

        } catch (Exception e) {
            return new DeviceControlResponse(OrderRespEnum.NO_PROTOCOL);
        }

    }

    @Override
    public DeviceControlResponse closeAll(DeviceControlRequest request) {
        return new DeviceControlResponse(OrderRespEnum.NO_PROTOCOL);
    }

    @Override
    public DeviceControlResponse queryStatus(DeviceControlRequest request) {
        try {
            Thread.sleep(2 * 1000);

            notifyWebInvoker.notifyAnalysisStatusSuccess(request.getCompanyId(), request.getSerId(), OrderRespEnum.MSG_SUCCESS, "状态查询成功……");

        } catch (Exception e) {

        }

        return new DeviceControlResponse(OrderRespEnum.ORDER_SUCCESS);
    }

    @Override
    public DeviceControlResponse tempControl(TempControlRequest request) {
        return new DeviceControlResponse(OrderRespEnum.NO_PROTOCOL);
    }

    @Override
    public DeviceControlResponse airAutoControl(DeviceAutoControlRequest request) {
        return new DeviceControlResponse(OrderRespEnum.NO_PROTOCOL);
    }

    @Override
    public DeviceControlResponse n2AutoControl(DeviceAutoControlRequest request) {
        return new DeviceControlResponse(OrderRespEnum.NO_PROTOCOL);
    }


}