消息回复代码优化

soc-modules/soc-modules-host/src/main/java/com/xunmei/host/video/service/impl/VideoDiagnosisRecordServiceImpl.java

@@ -67,6 +67,7 @@ public class VideoDiagnosisRecordServiceImpl extends ServiceImpl<VideoDiagnosisR
     private IotServerInfoService iotServerInfoService;
     @Resource
     IIotDeviceInfoService iotDeviceInfoService;
+
     @Override
     public ProductEnums product() {
         return ProductEnums.DVS;
@@ -100,11 +101,12 @@ public class VideoDiagnosisRecordServiceImpl extends ServiceImpl<VideoDiagnosisR
             dto.setProductName(obj.getProductName());
             dto.setDeviceName(obj.getDeviceName());
             dto.setToken(obj.getServerInfo().getIotCode());
-            return WebsocketResult.of(saveData(dto, obj.getId()), obj.getTopic(), obj.getId());
+            final ReceiveErrorDto saveData = saveData(dto, obj.getId());
+            final JSONObject jsb = WebsocketResult.dealReceiveErrorDto(saveData);
+            return WebsocketResult.reply(obj, jsb);
         } catch (Exception e) {
-            e.printStackTrace();
             LogUtils.STATUS_INFO_VIDEO_DIAGNOSIS.error(e.getMessage());
-            throw new RuntimeException(e);
+            throw new RuntimeException("处理视频质量数据发生异常",e);
         }
     }
 

soc-modules/soc-modules-host/src/main/java/com/xunmei/host/video/service/impl/VideoIntegrityCheckServiceImpl.java

@@ -127,7 +127,7 @@ public class VideoIntegrityCheckServiceImpl extends ServiceImpl<VideoIntegrityCh
             return WebsocketResult.reply(req, errorDto);
         }
 
-        return null;
+        return WebsocketResult.replySuccess(req);
     }
 
     @Override