优化报警

puzhibing

12 小时以前 4ad32c37e3317fb6cb7cbfb034b53d3220c27db4

 ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/server/DOWNRealvideoMsgStartupService.java

@@ -38,7 +38,7 @@
    *
    * @param vehicleNo
    */
   public R startupRealVideo(Integer inferiorPlatformId, String vehicleNo) {
   public R<String> startupRealVideo(Integer inferiorPlatformId, String vehicleNo) {
      Channel channel = ChannelMap.getClientChannel(inferiorPlatformId);
      if (!channel.isActive()) {
         return R.fail("失败");
@@ -47,7 +47,7 @@
      UPExgMsgRegister exgMsgRegister = upExgMsgRegisterDao.findByVehicleNo(vehicleNo);
      UPAuthorizeMsgStartup authorizeMsgStartup = upAuthorizeMsgStartupDao.findByInferiorPlatformIdOrderByCreateTimeDesc(inferiorPlatformId);
      if (null == authorizeMsgStartup) {
         return R.fail("获取失效口令失败");
         return R.fail("获取时效口令失败");
      }
      DOWNRealvideoMsgStartup downRealvideoMsgStartup = new DOWNRealvideoMsgStartup();
      downRealvideoMsgStartup.setVehicleNo(exgMsgRegister.getVehicleNo());
@@ -59,10 +59,10 @@
      downRealvideoMsgStartup.setAuthorizeCode(authorizeMsgStartup.getAuthorizeCode1());
      downRealvideoMsgStartup.setGnssData("");
      byte[] body = downRealvideoMsgStartup.encode();
      OuterPacket out = new OuterPacket(DataType.DOWN_REALVIDEO_MSG.getCode(), body);
      OuterPacket out = new OuterPacket(DataType.DOWN_REALVIDEO_MSG.getCode(), inferiorPlatformId, body);
      channel.writeAndFlush(out);
      log.info("发起实时音视频请求({})：{}", DataType.DOWN_REALVIDEO_MSG_STARTUP.getCode(), JSON.toJSONString(downRealvideoMsgStartup));
      return R.ok();
      return R.ok(authorizeMsgStartup.getAuthorizeCode1());
   }
   
}