package com.ld.igds.io.sample.lt;
|
|
import com.ld.igds.io.constant.ProtocolEnum;
|
import com.ld.igds.io.sample.ApiSampleService;
|
import com.ld.igds.io.sample.data.SampleDto;
|
import com.ld.igds.util.BytesUtil;
|
import com.ld.io.api.InvokeResult;
|
import io.netty.buffer.Unpooled;
|
import io.netty.channel.Channel;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* 扦样机执行接口
|
*
|
* @author: andy.jia
|
* @description:
|
* @version:
|
* @data:2020年4月11日
|
*
|
*/
|
@Slf4j
|
@Component(RemoteCheckServiceImpl.BEAN_ID)
|
public class RemoteCheckServiceImpl implements ApiSampleService {
|
|
public static final String BEAN_ID = "client.ltRemoteCheckServiceImpl";
|
|
@Override
|
public String getProtocol() {
|
return ProtocolEnum.TCP_LT_SAMPLE_V3.getCode();
|
}
|
|
/**
|
* 开始执行的逻辑: 1，自动开始工作（散粮）：00 00 00 00 00 06 01 06 00 07 00 19
|
* 2，扦样散粮车选择扦杆向下时吸粮：00 00 00 00 00 06 01 06 00 08 00 99 或者 扦样散粮车选择扦杆向上时吸粮：00
|
* 00 00 00 00 06 01 06 00 08 00 66
|
*
|
* @throws Exception
|
*/
|
@Override
|
public String doExe(SampleDto param) {
|
|
log.debug("开始扦样操作=={}", param.getIp());
|
try {
|
// 先发送状态查询，然后执行开始
|
String strMsg = OrderBulider.getInstance().buildStatus();
|
InvokeResult result = push(param.getIp(), param.getPort(), strMsg);
|
if (InvokeResult.SUCCESS != result) {
|
return "命令执行异常：" + result.getMessage();
|
}
|
if(LtCheckClientEngine.CHECK_MAC.get(param.getIp()) == null ){
|
LtCheckClientEngine.CHECK_MAC.put(param.getIp(),new LtCHeckMac());
|
}
|
// 判断状态
|
if ("0001".equals(LtCheckClientEngine.CHECK_MAC.get(param.getIp()).getHandStatus())) {
|
return "设备手动操作中";
|
}
|
if ("0012".equals(LtCheckClientEngine.CHECK_MAC.get(param.getIp()).getRunStatus())) {
|
return "当前设备正在执行中！";
|
}
|
if ("0011".equals(LtCheckClientEngine.CHECK_MAC.get(param.getIp()).getWarnStatus())) {
|
return "警告：伺服报警";
|
}
|
|
Thread.sleep(5000L);
|
|
// Step2 开始执行
|
strMsg = OrderBulider.getInstance().buildStart1Msg();
|
if (param.getType().equals(SampleDto.TYPE_SMALL)) {
|
strMsg = OrderBulider.getInstance().buildStart2Msg();
|
}
|
|
result = push(param.getIp(), param.getPort(), strMsg);
|
|
if (InvokeResult.SUCCESS != result) {
|
return "命令执行异常：" + result.getMessage();
|
}
|
|
// Step3 配置吸取粮食方式
|
strMsg = OrderBulider.getInstance().buildTypeDown();
|
|
result = push(param.getIp(), param.getPort(), strMsg);
|
if (InvokeResult.SUCCESS != result) {
|
return "命令执行异常：" + result.getMessage();
|
}
|
|
} catch (Exception e) {
|
log.error("执行异常：{}", e);
|
return "命令执行异常：" + e.getMessage();
|
}
|
|
return null;
|
}
|
|
@Override
|
public String doStop(SampleDto param) {
|
log.debug("停止扦样操作=={}", param.getIp());
|
try {
|
// 先发送状态查询，然后执行开始
|
String strMsg = OrderBulider.getInstance().buildStatus();
|
InvokeResult result = push(param.getIp(), param.getPort(), strMsg);
|
if (InvokeResult.SUCCESS != result) {
|
return "命令执行异常：" + result.getMessage();
|
}
|
|
|
if(LtCheckClientEngine.CHECK_MAC.get(param.getIp()) == null ){
|
LtCheckClientEngine.CHECK_MAC.put(param.getIp(),new LtCHeckMac());
|
}
|
// 判断状态
|
if ("0001".equals(LtCheckClientEngine.CHECK_MAC.get(param.getIp()).getHandStatus())) {
|
return "设备手动操作中";
|
}
|
if ("0001".equals(LtCheckClientEngine.CHECK_MAC.get(param.getIp()).getStopStatus())) {
|
return "急停按钮已经按下";
|
}
|
if ("0011".equals(LtCheckClientEngine.CHECK_MAC.get(param.getIp()).getWarnStatus())) {
|
return "警告：伺服报警";
|
}
|
|
// 创建命令
|
strMsg = OrderBulider.getInstance().buildStopMsg();
|
result = push(param.getIp(), param.getPort(), strMsg);
|
if (InvokeResult.SUCCESS != result) {
|
return "命令执行异常：" + result.getMessage();
|
}
|
|
} catch (Exception e) {
|
log.error("执行异常：{}", e);
|
return "命令执行异常：" + e.getMessage();
|
}
|
|
return null;
|
}
|
|
@Override
|
public String doResetStop(SampleDto param) {
|
log.debug("扦样机解除急停=={}", param.getIp());
|
|
// 创建命令
|
String strMsg = OrderBulider.getInstance().buildRestStopMsg();
|
|
InvokeResult result = push(param.getIp(), param.getPort(), strMsg);
|
if (InvokeResult.SUCCESS != result) {
|
return "命令执行异常：" + result.getMessage();
|
}
|
|
// 复位执行完成后不管什么状态-直接初始化
|
|
LtCHeckMac ltCHeckMac= new LtCHeckMac();
|
ltCHeckMac.setSerStart(true);
|
LtCheckClientEngine.CHECK_MAC.put(param.getIp(),ltCHeckMac);
|
return null;
|
}
|
@Override
|
public String doReset(SampleDto param) {
|
log.debug("扦样机复位指令=={}", param.getIp());
|
|
// 创建命令
|
String strMsg = OrderBulider.getInstance().buildRestMsg();
|
|
InvokeResult result = push(param.getIp(), param.getPort(), strMsg);
|
if (InvokeResult.SUCCESS != result) {
|
return "命令执行异常：" + result.getMessage();
|
}
|
|
// 复位执行完成后不管什么状态-直接初始化
|
|
LtCHeckMac ltCHeckMac= new LtCHeckMac();
|
ltCHeckMac.setSerStart(true);
|
LtCheckClientEngine.CHECK_MAC.put(param.getIp(),ltCHeckMac);
|
return null;
|
}
|
|
private InvokeResult push(String ip, int port, String msg) {
|
try {
|
LtCheckClientEngine clientEngine = new LtCheckClientEngine(
|
ip.trim(), port);
|
|
clientEngine.startRun();
|
|
Thread.sleep(2000L);
|
|
Channel channel = clientEngine.getChannel();
|
|
if (null == channel) {
|
return InvokeResult.SOCKET_NOT_CREATE;
|
}
|
if (!channel.isActive()) {
|
return InvokeResult.CHANNEL_CLOSED;
|
}
|
channel.writeAndFlush(
|
Unpooled.copiedBuffer(BytesUtil.hexStrToBytes(msg))).sync();
|
|
return InvokeResult.SUCCESS;
|
|
} catch (Exception e) {
|
log.error("执行异常：{}", e);
|
return InvokeResult.SOCKET_STATE_ERROR;
|
}
|
}
|
}
|
