package com.ld.igds.protocol.fzzy.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.fzzy.builder.EsCommandBuilder;
|
import com.ld.igds.protocol.fzzy.dto.SendMessage;
|
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 = "fzzy.remoteEsServiceImpl";
|
|
@Override
|
public BaseResponse checkEs(BaseRequest request) {
|
|
try {
|
// Step1 生成能耗命令
|
SendMessage 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());
|
}
|
}
|
}
|
