| | |
| | | @Resource |
| | | private BaseMsgService baseMsgService = SpringUtils.getBean(BaseMsgService.class); |
| | | |
| | | @Resource |
| | | private AuthorizeMsgService authorizeMsgService = SpringUtils.getBean(AuthorizeMsgService.class); |
| | | |
| | | @Resource |
| | | private RealvideoMsg realvideoMsg = SpringUtils.getBean(RealvideoMsg.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); |
| | | realvideoMsg.up_realvideo_msg(ctx, out); |
| | | break; |
| | | default: |
| | | break; |
| | | } |