工单获取图片ok

xiangpei

2024-08-28 c19666de02a21d62fb74c993a481141466111484

工单获取图片ok

 ycl-server/src/main/java/com/ycl/platform/service/WorkOrderService.java

@@ -9,6 +9,7 @@
import com.ycl.platform.domain.vo.screen.WorkOrderRegionVO;
import com.ycl.platform.domain.vo.screen.WorkOrderTotalVO;
import com.ycl.system.Result;
import org.bytedeco.javacv.FFmpegFrameGrabber;

import java.util.List;
import java.util.Map;
@@ -184,7 +185,7 @@
     * @param channelId 设备通道编号
     * @return 数据
     */
    String getFrameImgByDevice(String deviceId, String channelId);
    String getFrameImgByDevice(String deviceId, String channelId) throws FFmpegFrameGrabber.Exception;

    /**
     * 查询工单：已下发、已处理、已完成的工单

 ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java

@@ -1,6 +1,7 @@
package com.ycl.platform.service.impl;

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
@@ -662,60 +663,58 @@


    @Override
    public String getFrameImgByDevice(String deviceId, String channelId) {
    public String getFrameImgByDevice(String deviceId, String channelId) throws FFmpegFrameGrabber.Exception {
        String url = String.format(this.rtspServer + "/api/play/start/%s/%s", deviceId, channelId);
        String result = HttpUtils.sendGet(url);
        log.error("拿到取流响应结果：" + result);
// 假设WVPResult是正确解析响应的类
        WVPResult wvpResult = JSON.parseObject(result, WVPResult.class);
        if (0 == wvpResult.getCode()) {
            log.error("请求成功");
            StreamContent data = (StreamContent) wvpResult.getData();
            String rtspUrl = data.getRtsp();
            log.error("目标地址：" + rtspUrl);
        if (wvpResult.getCode() == 0) {
            System.out.println("请求成功");
            JSONObject data = (JSONObject) wvpResult.getData();
            String rtspUrl = data.getString("fmp4"); // 注意：通常RTSP URL不会以"fmp4"结尾，这里可能是特定API的返回格式
            if (StringUtils.hasText(rtspUrl)) {
                System.out.println("目标地址：" + rtspUrl);

                FFmpegFrameGrabber grabber = null;
                try {
                    FFmpegFrameGrabber grabber = FFmpegFrameGrabber.createDefault(rtspUrl);
                    grabber.setOption("rtsp_transport", "tcp"); // 使用tcp的方式，不然会丢包很严重
                    grabber.setImageWidth(960);
                    grabber.setImageHeight(540);
                    grabber = FFmpegFrameGrabber.createDefault(rtspUrl);
                    grabber.start();
                    CanvasFrame canvasFrame = new CanvasFrame("正茂");// 创建窗口
                    canvasFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);// 设置窗口关闭程序是否也跟随关闭
                    canvasFrame.setAlwaysOnTop(true);

                    OpenCVFrameConverter.ToMat converter = new OpenCVFrameConverter.ToMat();
                    int ex = 0;
                    String imgPath = null;
                    while (true) {
                        if (ex > 1) {
                            break;
                        }
                        Frame frame = grabber.grabImage();
                        canvasFrame.showImage(frame);
                        //程序到这里其实已经实现了预览的功能了，下面的方法就是将流保存成图片
                    Frame frame = grabber.grabImage(); // 直接捕获一帧
                    if (frame != null) {
                        System.out.println("成功捕获一帧");

                        //opencv_core.Mat
                        // 将Frame转换为Mat
                        OpenCVFrameConverter.ToMat converter = new OpenCVFrameConverter.ToMat();
                        Mat mat = converter.convertToMat(frame);
                        imgPath = serverConfig.getUrl() + PlatformConfig.getUploadPath() + deviceId + IdUtils.fastSimpleUUID() + ".png";
                        opencv_imgcodecs.imwrite(imgPath, mat);

                        ex++;
                        try {
                            Thread.sleep(1000);
                        }
                        catch (InterruptedException e)
                        {
                            e.printStackTrace();
                        } // 1000毫秒刷新一次圖像
                        // 生成图片路径
                        String imgPath = PlatformConfig.getUploadPath() + deviceId + IdUtils.fastSimpleUUID() + ".png";
                        System.out.println("图片地址：" + imgPath);

                        // 保存图片
                        opencv_imgcodecs.imwrite(imgPath, mat);
                    } else {
                        System.out.println("未捕获到帧");
                    }
                    grabber.stop(); // 停止捕获
                    grabber.release(); // 释放资源
                    return imgPath;
                } catch (IOException e) {
                } catch (FrameGrabber.Exception e) {
                    e.printStackTrace();
                } finally {
                    if (grabber != null) {
                        try {
                            grabber.stop(); // 停止捕获
                        } catch (FrameGrabber.Exception e) {
                            e.printStackTrace();
                        }
                        // 通常不需要调用release()，因为stop()会处理资源释放
                        // grabber.release(); // 释放资源
                    }
                }
            }
        } else {
            System.out.println("请求失败，错误码：" + wvpResult.getCode());
        }

        return null;
    }


 ycl-server/src/main/java/com/ycl/task/WorkOrderImgTask.java

@@ -7,6 +7,7 @@
import com.ycl.platform.service.WorkOrderService;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.bytedeco.javacv.FFmpegFrameGrabber;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
import org.springframework.util.StringUtils;
@@ -55,7 +56,12 @@
        for (DeviceInfoVO deviceInfo : deviceList) {
            executorService.submit(() -> {
                // 国标设备的编码就是取视频流的设备编码，国标设备就一个。国标设备的每一个通道代表一个摄像头，也就是设备id是取流的通道id
                String frameImg = workOrderService.getFrameImgByDevice(gbDevices.get(0).getDeviceId(), deviceInfo.getDeviceId());
                String frameImg = null;
                try {
                    frameImg = workOrderService.getFrameImgByDevice(gbDevices.get(0).getDeviceId(), deviceInfo.getDeviceId());
                } catch (FFmpegFrameGrabber.Exception e) {
                    e.printStackTrace();
                }
                if (StringUtils.hasText(frameImg)) {
                    workOrderService.updateImgById(deviceInfo.getWorkOrderId(), frameImg);
                }