|
@@ -246,7 +246,7 @@ public class StationMessageHandler extends ChannelInboundHandlerAdapter {
|
|
|
return;
|
|
|
}
|
|
|
BatGunStateDto dto = parse(stationMessage, BatGunStateDto.class);
|
|
|
- log.info("站控上传插枪信息:{}", dto);
|
|
|
+ //log.info("站控上传插枪信息:{}", dto);
|
|
|
dto.setStationCode(stationCode);
|
|
|
String topic = serverConfig.getServiceCenterName() + "_PERCEPTION_BAT_GUN_STATE";
|
|
|
kafkaTemplate.send(topic, JSON.toJSONString(dto));
|