package com.ld.igds.pressure;

import com.ld.igds.common.CoreCommonService;
import com.ld.igds.common.CoreDeviceService;
import com.ld.igds.common.CoreSerService;
import com.ld.igds.constant.BizType;
import com.ld.igds.io.N2RemoteManager;
import com.ld.igds.io.RemotePressureService;
import com.ld.igds.io.constant.OrderRespEnum;
import com.ld.igds.io.request.BaseRequest;
import com.ld.igds.io.response.BaseResponse;
import com.ld.igds.models.Device;
import com.ld.igds.models.DeviceSer;
import com.ld.igds.order.ExeOrderService;
import com.ld.igds.order.data.ExeRequest;
import com.ld.igds.util.ContextUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.List;

/**
 * 气压管理
 *
 * @author: andy.jia
 * @description:
 * @version:
 * @data:2020年2月17日
 */
@Slf4j
@Component
public class PressureManager {

    @Autowired
    private N2RemoteManager remoteManager;
    @Autowired
    private ExeOrderService exeOrderService;
    @Autowired
    private CoreSerService coreSerService;

    /**
     * 根据基础请求参数执行气压检测
     *
     * @param request
     */
    public void checkByRequest(BaseRequest request) {

        if (null == request.getBizType()) {
            request.setBizType(BizType.N2.getCode());
        }

        if (null == request.getProtocol()) {
            log.error("---------自动检测压力，没有获取到协议信息-----{}", request.toString());
            return;
        }

        RemotePressureService remoteService = remoteManager.getRemotePressureService(request.getProtocol());
        if (null == remoteService) {
            log.error("---------自动检测压力，当前协议下没有接口实现-----{}--{}", request.getSerName(), request.getProtocol());
            return;
        }

        ExeRequest exeRequest = new ExeRequest(request);
        exeRequest.setRepeatTag(true);
        exeOrderService.checkExecute(exeRequest);
        BaseResponse response = remoteService.checkPressure(request);
        if (OrderRespEnum.ORDER_SUCCESS.getCode().equals(response.getCode())) {
            exeOrderService.addCache(exeRequest);
        }

    }


    public void checkAll() {
        String defaultCompanyId = ContextUtil.getDefaultCompanyId();
        //获取分机信息
        List<DeviceSer> listSer = coreSerService.getCacheSerList(defaultCompanyId);
        if (null == listSer) return;

        BaseRequest baseRequest;
        for (DeviceSer ser: listSer ) {
            baseRequest = new BaseRequest();
            baseRequest.setCompanyId(ser.getCompanyId());
            baseRequest.setSerName(ser.getName());
            baseRequest.setSerId(ser.getId());
            baseRequest.setIp(ser.getIp());
            baseRequest.setPort(ser.getPort());
            baseRequest.setProtocol(ser.getProtocol());

            checkByRequest(baseRequest);
        }



    }
}