| | |
| | | @Resource |
| | | private BaseMsgService baseMsgService = SpringUtils.getBean(BaseMsgService.class); |
| | | |
| | | @Resource |
| | | private AuthorizeMsgService authorizeMsgService = SpringUtils.getBean(AuthorizeMsgService.class); |
| | | |
| | | @Resource |
| | | private RealvideoMsgService realvideoMsgService = SpringUtils.getBean(RealvideoMsgService.class); |
| | | |
| | | @Resource |
| | | private PlaybackMsgService playbackMsgService = SpringUtils.getBean(PlaybackMsgService.class); |
| | | |
| | | |
| | | @Override |
| | | public void channelRead(ChannelHandlerContext ctx, Object object) throws Exception { |
| | |
| | | log.info("车辆静态信息交换业务({}):{}", DataType.UP_BASE_MSG.getCode(), out); |
| | | baseMsgService.up_base_msg(ctx, out); |
| | | break; |
| | | case UP_AUTHORIZE_MSG: |
| | | log.info("视频时效口令交互({}):{}", DataType.UP_AUTHORIZE_MSG.getCode(), out); |
| | | authorizeMsgService.up_authorize_msg(ctx, out); |
| | | break; |
| | | case UP_REALVIDEO_MSG: |
| | | log.info("实时音视频交互({}):{}", DataType.UP_REALVIDEO_MSG.getCode(), out); |
| | | realvideoMsgService.up_realvideo_msg(ctx, out); |
| | | break; |
| | | case UP_PLAYBACK_MSG: |
| | | log.info("远程录像回放交互({}):{}", DataType.UP_PLAYBACK_MSG.getCode(), out); |
| | | playbackMsgService.up_playback_msg(ctx, out); |
| | | break; |
| | | default: |
| | | break; |
| | | } |