|
|
@@ -23,6 +23,7 @@ import com.xunmei.host.video.service.IVideoDiagnosisLogService;
|
|
|
import com.xunmei.host.video.service.IVideoDiagnosisRecordService;
|
|
|
import com.xunmei.host.websocket.constant.WebSocketConstants;
|
|
|
import com.xunmei.host.websocket.dto.WebsocketExecuteReq;
|
|
|
+import com.xunmei.host.websocket.dto.WebsocketResult;
|
|
|
import com.xunmei.host.websocket.enums.ProductEnums;
|
|
|
import com.xunmei.host.websocket.redis.RedisKey;
|
|
|
import com.xunmei.host.websocket.service.RouterService;
|
|
|
@@ -99,7 +100,7 @@ public class VideoDiagnosisRecordServiceImpl extends ServiceImpl<VideoDiagnosisR
|
|
|
dto.setProductName(obj.getProductName());
|
|
|
dto.setDeviceName(obj.getDeviceName());
|
|
|
dto.setToken(obj.getServerInfo().getIotCode());
|
|
|
- return null;
|
|
|
+ return WebsocketResult.of(saveData(dto, obj.getId()), obj.getTopic(), obj.getId());
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
LogUtils.STATUS_INFO_VIDEO_DIAGNOSIS.error(e.getMessage());
|