|
@@ -159,11 +159,11 @@ public class StationMessageHandler extends ChannelInboundHandlerAdapter {
|
|
if (StringUtils.isBlank(stationCode)) {
|
|
if (StringUtils.isBlank(stationCode)) {
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
- log.info("================可用电池数HASH:{}",BytesUtil.bytesToHexString(stationMessage.getData()));
|
|
|
|
|
|
+ //log.info("================可用电池数HASH:{}",BytesUtil.bytesToHexString(stationMessage.getData()));
|
|
PerceptionUploadAvailableBatsDto dto = parse(stationMessage, PerceptionUploadAvailableBatsDto.class);
|
|
PerceptionUploadAvailableBatsDto dto = parse(stationMessage, PerceptionUploadAvailableBatsDto.class);
|
|
dto.setStationCode(stationCode);
|
|
dto.setStationCode(stationCode);
|
|
String topic = serverConfig.getServiceCenterName() + "_PERCEPTION_BAT_AVAILABLE";
|
|
String topic = serverConfig.getServiceCenterName() + "_PERCEPTION_BAT_AVAILABLE";
|
|
- log.info("================可用电池数:{}",dto);
|
|
|
|
|
|
+ //log.info("================可用电池数:{}",dto);
|
|
kafkaTemplate.send(topic, JSON.toJSONString(dto));
|
|
kafkaTemplate.send(topic, JSON.toJSONString(dto));
|
|
} else if (command.equals(StationMessage.CommandType.PERCEPTION_PLC)) {
|
|
} else if (command.equals(StationMessage.CommandType.PERCEPTION_PLC)) {
|
|
//plc感知
|
|
//plc感知
|
|
@@ -246,7 +246,7 @@ public class StationMessageHandler extends ChannelInboundHandlerAdapter {
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
BatGunStateDto dto = parse(stationMessage, BatGunStateDto.class);
|
|
BatGunStateDto dto = parse(stationMessage, BatGunStateDto.class);
|
|
- //log.info("站控上传插枪信息:{}", dto);
|
|
|
|
|
|
+ log.info("站控上传插枪信息:{}", dto);
|
|
dto.setStationCode(stationCode);
|
|
dto.setStationCode(stationCode);
|
|
String topic = serverConfig.getServiceCenterName() + "_PERCEPTION_BAT_GUN_STATE";
|
|
String topic = serverConfig.getServiceCenterName() + "_PERCEPTION_BAT_GUN_STATE";
|
|
kafkaTemplate.send(topic, JSON.toJSONString(dto));
|
|
kafkaTemplate.send(topic, JSON.toJSONString(dto));
|