package com.ld.igds.protocol.zldz.command;
|
|
import com.ld.igds.io.RemoteGrainService;
|
import com.ld.igds.io.constant.OrderRespEnum;
|
import com.ld.igds.io.request.BaseRequest;
|
import com.ld.igds.io.request.CheckGrainRequest;
|
import com.ld.igds.io.response.BaseResponse;
|
import com.ld.igds.io.response.GrainResponse;
|
import com.ld.igds.protocol.zldz.command.builder.CommandBuilder1115;
|
import com.ld.igds.protocol.zldz.command.builder.CommandBuilder8815;
|
import com.ld.igds.protocol.zldz.command.builder.CommandBuilder8817;
|
import com.ld.igds.protocol.zldz.command.message.Message;
|
import com.ld.igds.protocol.zldz.task.CommandReSendService;
|
import com.ld.igds.protocol.zldz.task.CommandTask;
|
import com.ld.igds.protocol.zldz.util.ServerUtils;
|
import com.ld.io.api.InvokeResult;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* 粮情协议，直接获取粮情，温湿度信息通过心跳定时获取。
|
*
|
* @author jiazx
|
*/
|
@Slf4j
|
@Component(RemoteGrainServiceImpl.BEAN_ID)
|
public class RemoteGrainServiceImpl extends BaseRemoteImpl implements
|
RemoteGrainService {
|
|
public static final String BEAN_ID = "zldz.remoteGrainService";
|
|
@Autowired
|
private CommandReSendService commandReSendService;
|
|
/**
|
* 粮情检测，首先需要执行温湿度检测，温湿度检测完成后，再进粮情检测。
|
* 温湿度的信息根据分机和温湿度地址存在缓存30分钟，30分钟内不重复采集，系统判断与当前时间差距离当前时间是否超过25分钟
|
* ，超过重新获取，没有超过直接采集粮情
|
*
|
* @param request
|
* @return
|
*/
|
@Override
|
public GrainResponse checkGrain(CheckGrainRequest request) {
|
// Step1 生成粮情信息
|
Message message = CommandBuilder1115.getInstance().buildMessage(request);
|
|
log.info("平台------>>>分机：" +request.getSerName() + "-粮情采集命令=" + message.toString());
|
|
InvokeResult result = send(request.getIp(), request.getPort(), message.getByteMsg());
|
|
// 封装返回信息
|
if (InvokeResult.SUCCESS == result) {
|
CommandTask commandData = new CommandTask();
|
commandData.setCompanyId(request.getCompanyId());
|
commandData.setIp(request.getIp());
|
commandData.setPort(request.getPort());
|
commandData.setByteCommand(message.getByteMsg());
|
commandData.setCommand(message.getStrMsg());
|
commandData.setResultType(ServerUtils.MSG_TYPE_8817);
|
commandData.setCableRule(request.getCableRule());
|
commandData.setSerName(request.getSerName());
|
commandData.setDepotId(request.getDepotId());
|
commandReSendService.reSendGrainTask(commandData);
|
return new GrainResponse(OrderRespEnum.ORDER_SUCCESS.getCode(),
|
"粮情采集命令发送成功");
|
} else {
|
log.info("分机" + request.getSerName() + "粮情采集命令发送失败：" + result.getMessage());
|
return new GrainResponse(OrderRespEnum.ORDER_ERROR.getCode(), result.getMessage());
|
}
|
}
|
|
/**
|
* 服务器回复终端的收到请求
|
*
|
* @param request
|
*/
|
public BaseResponse reply8815(BaseRequest request) {
|
// Step1 生成粮情信息
|
Message message = CommandBuilder8815.getInstance().buildMessage(
|
request);
|
|
log.debug("平台------>>>分机：" +request.getSerName() + "-粮情服务端回复命令=" + message.toString());
|
|
// 发送命令
|
InvokeResult result = send(request.getIp(), request.getPort(),
|
message.getByteMsg());
|
// 封装返回信息
|
if (InvokeResult.SUCCESS == result) {
|
return new BaseResponse(OrderRespEnum.ORDER_SUCCESS.getCode(),
|
"分机" + request.getSerName() + "粮情服务端回复命令发送成功");
|
} else {
|
log.error("分机" + request.getSerName() + "粮情服务端回复命令发送失败：" + result.getMessage());
|
return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(),
|
"分机" + request.getSerName() + "粮情服务端回复命令发送失败：" + result.getMessage());
|
}
|
}
|
|
/**
|
* 回复命令
|
*
|
* @param request
|
* @param hexCurPacket 当前包的hex
|
*/
|
public BaseResponse reply8817(BaseRequest request, String hexCurPacket) {
|
// Step1 生成粮情信息，把信息放在request
|
request.setBizType(hexCurPacket);
|
|
Message message = CommandBuilder8817.getInstance().buildMessage(request);
|
|
log.debug("平台------>>>分机：" +request.getSerName() + "-粮情服务端回复收到粮情包命令=" + message.toString());
|
|
// 发送命令
|
InvokeResult result = send(request.getIp(), request.getPort(),
|
message.getByteMsg());
|
|
// 封装返回信息
|
if (InvokeResult.SUCCESS == result) {
|
return new BaseResponse(OrderRespEnum.ORDER_SUCCESS.getCode(),
|
"分机" + request.getSerName() + "粮情服务端回复收到粮情包命令发送成功");
|
} else {
|
log.info("分机" + request.getSerName() + "粮情服务端回复收到粮情包命令发送失败：" + result.getMessage());
|
|
return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(),
|
"分机" + request.getSerName() + "粮情服务端回复收到粮情包命令发送失败：" + result.getMessage());
|
}
|
}
|
}
|
