package com.ld.igds.protocol.bhzn.grainv2;
|
|
import com.ld.igds.common.CoreCommonService;
|
import com.ld.igds.io.RemoteGrainService;
|
import com.ld.igds.io.constant.OrderRespEnum;
|
import com.ld.igds.io.constant.ProtocolEnum;
|
import com.ld.igds.io.request.CheckGrainRequest;
|
import com.ld.igds.io.response.GrainResponse;
|
import com.ld.igds.models.Depot;
|
import com.ld.igds.protocol.bhzn.grainv2.msg.builder.CommandBuild;
|
import com.ld.igds.protocol.bhzn.grainv2.server.BhznGrainV2ServerEngine;
|
import com.ld.igds.util.BytesUtil;
|
import com.ld.io.api.InvokeResult;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
|
/**
|
* @Desc: 粮情业务接口
|
* @author: Andy
|
* @update-time: 2023/5/11
|
*/
|
@Slf4j
|
@Component(RemoteGrainV2ServiceImpl.BEAN_ID)
|
public class RemoteGrainV2ServiceImpl implements RemoteGrainService {
|
|
public static final String BEAN_ID = "bhznGrainv2.remoteGrainService";
|
|
@Autowired
|
private CoreCommonService coreCommonService;
|
@Autowired
|
private BhznGrainV2ServerEngine bhznGrainServerEngine;
|
|
@Override
|
public String getProtocol() {
|
return ProtocolEnum.TCP_BHZH_GRAIN_V2.getCode();
|
}
|
|
@Override
|
public GrainResponse checkGrain(CheckGrainRequest request) {
|
try {
|
String depotId = request.getDepotId();
|
|
//判断邦海仓库编码是否配置
|
Depot depot = coreCommonService.getCacheDepot(request.getCompanyId(), request.getDepotId());
|
if(null != depot && StringUtils.isNotEmpty(depot.getBhId())){
|
depotId = depot.getBhId();
|
}
|
|
// 生成粮情信息
|
String hexStr = CommandBuild.getInstance().getMsgCheck(request.getSerId(), depotId);
|
|
// 发送命令
|
InvokeResult result = bhznGrainServerEngine.push(request.getIp(),request.getPort(), BytesUtil.hexStrToBytes(hexStr));
|
|
log.error("平台------>>>>控制柜：粮情检测-{}", hexStr);
|
|
// 封装返回信息
|
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 GrainResponse(OrderRespEnum.ORDER_ERROR.getCode(), "后端异常：" + e.getMessage());
|
}
|
}
|
}
|
