package com.ld.igds.protocol.fzzy.command;
|
|
import com.ld.igds.constant.BizType;
|
import com.ld.igds.io.RemoteCommonService;
|
import com.ld.igds.io.notify.NotifyWebInvoker;
|
import com.ld.igds.io.constant.OrderRespEnum;
|
import com.ld.igds.io.request.*;
|
import com.ld.igds.io.response.BaseResponse;
|
import com.ld.igds.io.response.DeviceControlResponse;
|
import com.ld.igds.protocol.fzzy.builder.PullAccessCommandBuilder;
|
import com.ld.igds.protocol.fzzy.builder.PullDepotCommandBuilder;
|
import com.ld.igds.protocol.fzzy.builder.PullDepotStatusCommandBuilder;
|
import com.ld.igds.protocol.fzzy.builder.PullDeviceCommandBuilder;
|
import com.ld.igds.protocol.fzzy.dto.SendMessage;
|
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(RemoteCommonImpl.BEAN_ID)
|
public class RemoteCommonImpl extends BaseRemoteImpl implements RemoteCommonService {
|
|
public static final String BEAN_ID = "fzzy.remoteCommonService";
|
|
@Autowired
|
private NotifyWebInvoker notifyWebInvoker;
|
|
@Override
|
public BaseResponse checkTh(CheckThRequest request) {
|
return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(), "协议不支持");
|
}
|
|
@Override
|
public BaseResponse pullDevice(BaseRequest request) {
|
SendMessage message = PullDeviceCommandBuilder.getInstance().buildMessage(request);
|
|
log.info("平台------>>>>控制柜：获取控制柜设备信息-{}", message.getStrMsg());
|
|
InvokeResult result = send(request.getIp(), request.getPort(), message.getByteMsg());
|
|
// 如果有执行异常，直接通知到前端
|
if (InvokeResult.SUCCESS != result) {
|
log.error("平台------>>>>控制柜：获取控制柜设备信息-执行失败：{}",result.getMessage());
|
notifyWebInvoker.notifyWeb(request.getCompanyId(), OrderRespEnum.ORDER_ERROR, BizType.SYS, request.getSerName() + " 远程同步控制柜设备信息，命令执行失败");
|
}
|
return new DeviceControlResponse(OrderRespEnum.ORDER_SUCCESS);
|
}
|
|
|
@Override
|
public BaseResponse pullDepot(BaseRequest request) {
|
SendMessage message = PullDepotCommandBuilder.getInstance().buildMessage(request);
|
|
log.info("平台------>>>>控制柜：获取控制柜仓库信息-{}", message.getStrMsg());
|
|
InvokeResult result = send(request.getIp(), request.getPort(), message.getByteMsg());
|
|
// 如果有执行异常，直接通知到前端
|
if (InvokeResult.SUCCESS != result) {
|
log.info("平台------>>>>控制柜：获取控制柜仓库信息-失败{}", result.getMessage());
|
notifyWebInvoker.notifyWeb(request.getCompanyId(), OrderRespEnum.ORDER_ERROR, BizType.SYS, request.getSerName() + " 远程同步控制柜设备信息，命令执行失败");
|
}
|
return new DeviceControlResponse(OrderRespEnum.ORDER_SUCCESS);
|
}
|
|
@Override
|
public BaseResponse pullAccess(AccessRequest request) {
|
SendMessage message = PullAccessCommandBuilder.getInstance().buildMessage(request);
|
|
|
log.info("平台------>>>>控制柜：执行命令发送-{}", message.getStrMsg());
|
|
InvokeResult result = send(request.getIp(), request.getPort(), message.getByteMsg());
|
|
// 如果有执行异常，直接通知到前端
|
if (InvokeResult.SUCCESS != result) {
|
log.info("平台------>>>>控制柜：执行命令发送-失败-{}", result.getMessage());
|
notifyWebInvoker.notifyWeb(request.getCompanyId(), OrderRespEnum.ORDER_ERROR, BizType.SYS, request.getSerName() + " 远程同步控制柜设备信息，命令执行失败");
|
}
|
return new DeviceControlResponse(OrderRespEnum.ORDER_SUCCESS);
|
}
|
|
@Override
|
public BaseResponse pullDepotStatus(DepotStatusRequest request) {
|
|
SendMessage message = PullDepotStatusCommandBuilder.getInstance().buildMessage(request);
|
|
log.info("平台------>>>>控制柜：执行命令发送-{}", message.getStrMsg());
|
|
InvokeResult result = send(request.getIp(), request.getPort(), message.getByteMsg());
|
|
// 如果有执行异常，直接通知到前端
|
if (InvokeResult.SUCCESS != result) {
|
log.info("平台------>>>>控制柜：执行命令发送-失败-{}", result.getMessage());
|
notifyWebInvoker.notifyWeb(request.getCompanyId(), OrderRespEnum.ORDER_ERROR, BizType.SYS, request.getDepotName() + " 远程推送仓库状态，命令执行失败");
|
}
|
|
return new DeviceControlResponse(OrderRespEnum.ORDER_SUCCESS);
|
}
|
|
@Override
|
public BaseResponse heartBeat(BaseRequest request) {
|
return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(), "协议不支持");
|
}
|
|
@Override
|
public BaseResponse readConf(GrainSerConfRequest request) {
|
return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(), "协议不支持");
|
}
|
|
@Override
|
public BaseResponse writeConf(GrainSerConfRequest request) {
|
return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(), "协议不支持");
|
}
|
|
@Override
|
public BaseResponse initCable(BaseRequest request) {
|
return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(), "协议不支持");
|
}
|
|
@Override
|
public BaseResponse updateGrainSerCable(GrainSerConfRequest request) {
|
return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(), "协议不支持");
|
}
|
|
@Override
|
public BaseResponse destroyCon(BaseRequest request) {
|
return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(), "协议不支持");
|
}
|
|
@Override
|
public BaseResponse checkGrainSerCable(GrainSerConfRequest request) {
|
return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(), "协议不支持");
|
}
|
|
@Override
|
public BaseResponse sumGrainSerCable(GrainSerConfRequest request) {
|
return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(), "协议不支持");
|
}
|
|
@Override
|
public BaseResponse updateSysDepotConf(BaseRequest request) {
|
return null;
|
}
|
|
}
|
