package com.ld.igds.protocol.es.dlt645;
|
|
import com.ld.igds.constant.RedisConst;
|
import com.ld.igds.io.RemoteEsService;
|
import com.ld.igds.io.constant.OrderRespEnum;
|
import com.ld.igds.io.constant.ProtocolEnum;
|
import com.ld.igds.io.request.BaseRequest;
|
import com.ld.igds.io.response.BaseResponse;
|
import com.ld.igds.io.response.GrainResponse;
|
import com.ld.igds.protocol.es.dlt645.builder.CommandBuild;
|
import com.ld.igds.protocol.es.dlt645.client.Dlt645ClientEngine;
|
import com.ld.igds.util.BytesUtil;
|
import com.ld.igds.util.RedisUtil;
|
import com.ld.io.api.InvokeResult;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* 当前协议实现，能耗协议
|
*
|
* @author czt
|
*/
|
@Slf4j
|
@Component(RemoteEsServiceImpl.BEAN_ID)
|
public class RemoteEsServiceImpl implements RemoteEsService {
|
|
public static final String BEAN_ID = "dlt645.remoteEsServiceImpl";
|
|
@Autowired
|
private RedisUtil redisUtil;
|
@Override
|
public String getProtocol() {
|
return ProtocolEnum.TCP_ES_DLT645_V1.getCode();
|
}
|
|
@Override
|
public BaseResponse checkEs(BaseRequest request) {
|
|
try {
|
log.info("DL/T645多功能电表分机开始检测，分机{}的IP={},端口={}",request.getSerId(),request.getIp(),request.getPort());
|
|
Dlt645ClientEngine clientEngine = new Dlt645ClientEngine(request.getIp(), request.getPort());
|
clientEngine.start();
|
Thread.sleep(1000);
|
|
//采集命令存入缓存，解析时分辨是哪个仓的能耗，时效5分钟
|
String key = RedisConst.buildKey(request.getCompanyId(), "ES-DLT645", request.getSerId());
|
redisUtil.set(key, request.getDepotId(), 60*5);
|
|
//生成命令-查询总电能的命令
|
String hexStr = CommandBuild.getInstance().getMsgCheck(request.getSerId());
|
|
InvokeResult result = clientEngine.send(BytesUtil.hexStrToBytes(hexStr));
|
|
log.info("result=" +result.getMessage());
|
|
// 封装返回信息
|
if (InvokeResult.SUCCESS == result) {
|
return new GrainResponse(OrderRespEnum.ORDER_SUCCESS.getCode(),
|
"能耗命令发送成功！");
|
} else {
|
log.error("平台------>>>>能耗分机：能耗检测-失败{}", result.getMessage());
|
return new GrainResponse(OrderRespEnum.ORDER_ERROR.getCode(),
|
"命令发送异常：" + result.getMessage());
|
}
|
|
} catch (Exception e) {
|
log.error("能耗检测异常：{}", e);
|
return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(), "后端异常：" + e.getMessage());
|
}
|
}
|
}
|
