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

import com.ld.igds.io.RemoteEsService;
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.protocol.bhzn.verb.builder.EsCommandBuilder;
import com.ld.igds.protocol.bhzn.verb.dto.IoMessage;
import com.ld.io.api.InvokeResult;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

/**
 * 当前协议实现，能耗协议
 *
 * @author jiazx
 */
@Slf4j
@Component(RemoteEsServiceImpl.BEAN_ID)
public class RemoteEsServiceImpl extends BaseRemoteImpl implements RemoteEsService {

    public static final String BEAN_ID = "bhzn.remoteEsServiceImpl";

    @Override
    public BaseResponse checkEs(BaseRequest request) {

        try {
            // Step1 生成能耗命令
            IoMessage message = EsCommandBuilder.getInstance().buildMessage(request);
            InvokeResult result = send(request.getIp(), request.getPort(), message.getByteMsg());

            log.error("平台------>>>>控制柜：能耗查询-{}", message.toString());

            if (InvokeResult.SUCCESS == result) {
                return new BaseResponse(OrderRespEnum.ORDER_SUCCESS.getCode(),
                        "能耗命令发送成功！");
            } else {
                log.error("平台------>>>>控制柜：能耗查询-失败{}", result.getMessage());
                return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(),
                        "命令发送异常：" + result.getMessage());
            }

        } catch (Exception e) {
            log.error("能耗检测异常：{}", e);
            return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(), "后端异常：" + e.getMessage());
        }
    }
}