| | |
| | | |
| | | @Override |
| | | public synchronized String getFrameImgByDevice(String deviceId, String channelId, String workOrderNo) throws Exception { |
| | | String url = String.format(this.rtspServer + "/api/play/start/%s/%s", deviceId, channelId); |
| | | String url = String.format(this.rtspServer + "/api/play/start/img/%s/%s", deviceId, channelId); |
| | | String result = HttpUtils.sendGet(url); |
| | | log.info("拿到取流响应结果:" + result); |
| | | WVPResult wvpResult = JSON.parseObject(result, WVPResult.class); |
| | | String imgUrl = null; |
| | | if (wvpResult.getCode() == 0) { |
| | | JSONObject data = (JSONObject) wvpResult.getData(); |
| | | String rtspUrl = data.getString("fmp4"); // 取mp4地址 |
| | | if (StringUtils.hasText(rtspUrl)) { |
| | | System.out.println("目标地址:" + rtspUrl); |
| | | FFmpegFrameGrabber grabber = null; |
| | | try { |
| | | grabber = new FFmpegFrameGrabber(rtspUrl); |
| | | // grabber.setOption("rtsp_transport", "tcp"); // 使用tcp的方式,不然会丢包很严重 |
| | | // grabber.setVideoOption("probesize", "10000"); // 设置捕获分析的最大字节 |
| | | grabber.start(); |
| | | Frame frame = grabber.grabImage(); // 直接捕获一帧 |
| | | if (frame != null) { |
| | | System.out.println("成功捕获一帧"); |
| | | // 将Frame转换为Mat |
| | | OpenCVFrameConverter.ToMat converter = new OpenCVFrameConverter.ToMat(); |
| | | Mat mat = converter.convertToMat(frame); |
| | | |
| | | imgUrl = workOrderNo + "_" + IdUtils.fastSimpleUUID() + ".png"; |
| | | // 生成图片路径 |
| | | String imgPath = PlatformConfig.getProfile() + "/" + imgUrl; |
| | | System.out.println("图片保存地址:" + imgPath); |
| | | imgUrl = Constants.RESOURCE_PREFIX + "/" + imgUrl; |
| | | // 保存图片 |
| | | opencv_imgcodecs.imwrite(imgPath, mat); |
| | | } else { |
| | | System.out.println("未捕获到帧"); |
| | | } |
| | | } catch (FrameGrabber.Exception e) { |
| | | e.printStackTrace(); |
| | | } finally { |
| | | if (grabber != null) { |
| | | try { |
| | | grabber.stop(); // 停止捕获 |
| | | } catch (FrameGrabber.Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | } else { |
| | | System.out.println("请求失败,错误码:" + wvpResult.getCode() + "--" + wvpResult.getMsg()); |
| | | } |
| | | System.out.println("图片URL:" + imgUrl); |
| | | return imgUrl; |
| | | log.info("拿到取流图片响应结果:" + result); |
| | | return result; |
| | | // WVPResult wvpResult = JSON.parseObject(result, WVPResult.class); |
| | | // String imgUrl = null; |
| | | // if (wvpResult.getCode() == 0) { |
| | | // JSONObject data = (JSONObject) wvpResult.getData(); |
| | | // String rtspUrl = data.getString("fmp4"); // 取mp4地址 |
| | | // if (StringUtils.hasText(rtspUrl)) { |
| | | // System.out.println("目标地址:" + rtspUrl); |
| | | // FFmpegFrameGrabber grabber = null; |
| | | // try { |
| | | // grabber = new FFmpegFrameGrabber(rtspUrl); |
| | | //// grabber.setOption("rtsp_transport", "tcp"); // 使用tcp的方式,不然会丢包很严重 |
| | | //// grabber.setVideoOption("probesize", "10000"); // 设置捕获分析的最大字节 |
| | | // grabber.start(); |
| | | // Frame frame = grabber.grabImage(); // 直接捕获一帧 |
| | | // if (frame != null) { |
| | | // System.out.println("成功捕获一帧"); |
| | | // // 将Frame转换为Mat |
| | | // OpenCVFrameConverter.ToMat converter = new OpenCVFrameConverter.ToMat(); |
| | | // Mat mat = converter.convertToMat(frame); |
| | | // |
| | | // imgUrl = workOrderNo + "_" + IdUtils.fastSimpleUUID() + ".png"; |
| | | // // 生成图片路径 |
| | | // String imgPath = PlatformConfig.getProfile() + "/" + imgUrl; |
| | | // System.out.println("图片保存地址:" + imgPath); |
| | | // imgUrl = Constants.RESOURCE_PREFIX + "/" + imgUrl; |
| | | // // 保存图片 |
| | | // opencv_imgcodecs.imwrite(imgPath, mat); |
| | | // } else { |
| | | // System.out.println("未捕获到帧"); |
| | | // } |
| | | // } catch (FrameGrabber.Exception e) { |
| | | // e.printStackTrace(); |
| | | // } finally { |
| | | // if (grabber != null) { |
| | | // try { |
| | | // grabber.stop(); // 停止捕获 |
| | | // } catch (FrameGrabber.Exception e) { |
| | | // e.printStackTrace(); |
| | | // } |
| | | // } |
| | | // } |
| | | // } |
| | | // } else { |
| | | // System.out.println("请求失败,错误码:" + wvpResult.getCode() + "--" + wvpResult.getMsg()); |
| | | // } |
| | | // System.out.println("图片URL:" + imgUrl); |
| | | // return imgUrl; |
| | | } |
| | | |
| | | @Override |