|
@@ -163,7 +163,7 @@ public class StationMessageHandler extends ChannelInboundHandlerAdapter {
|
|
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感知
|