From d1e30de4ca5e1c198df2edd0394779f93ae80f64 Mon Sep 17 00:00:00 2001 From: xiangpei <xiangpei@timesnew.cn> Date: 星期四, 29 八月 2024 14:59:10 +0800 Subject: [PATCH] 定时任务注释解开 --- ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java | 75 +++++++++++++++++++++++-------------- 1 files changed, 47 insertions(+), 28 deletions(-) diff --git a/ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java b/ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java index 5cd3093..8f4d81d 100644 --- a/ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java +++ b/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; @@ -37,6 +38,7 @@ import com.ycl.utils.http.HttpUtils; import com.ycl.utils.redis.RedisCache; import com.ycl.utils.uuid.IdUtils; +import constant.Constants; import enumeration.general.NotifyTypeEnum; import enumeration.general.UrgentLevelEnum; import enumeration.general.WorkOrderDistributeWayEnum; @@ -44,9 +46,9 @@ import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.ObjectUtils; -import org.bytedeco.javacv.FFmpegFrameGrabber; -import org.bytedeco.javacv.Frame; -import org.bytedeco.javacv.Java2DFrameConverter; +import org.bytedeco.javacv.*; +import org.bytedeco.opencv.global.opencv_imgcodecs; +import org.bytedeco.opencv.opencv_core.Mat; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; @@ -57,6 +59,7 @@ import org.springframework.util.StringUtils; import javax.imageio.ImageIO; +import javax.swing.*; import java.awt.image.BufferedImage; import java.io.File; import java.io.IOException; @@ -661,41 +664,56 @@ @Override - public String getFrameImgByDevice(String deviceId, String channelId) { + public String getFrameImgByDevice(String deviceId, String channelId, String workOrderNo) { String url = String.format(this.rtspServer + "/api/play/start/%s/%s", deviceId, channelId); String result = HttpUtils.sendGet(url); - log.error("鎷垮埌鍙栨祦鍝嶅簲缁撴灉锛�" + result); WVPResult wvpResult = JSON.parseObject(result, WVPResult.class); - if (0 == wvpResult.getCode()) { - log.error("璇锋眰鎴愬姛"); - StreamContent data = (StreamContent) wvpResult.getData(); - log.error("鎷垮埌鍙栨祦鍝嶅簲缁撴灉锛�" + data); - String rtspUrl = data.getRtsp(); + String imgUrl = null; + if (wvpResult.getCode() == 0) { + JSONObject data = (JSONObject) wvpResult.getData(); + String rtspUrl = data.getString("fmp4"); // 鍙杕p4鍦板潃 if (StringUtils.hasText(rtspUrl)) { + System.out.println("鐩爣鍦板潃锛�" + rtspUrl); + FFmpegFrameGrabber grabber = null; try { - // 鍒涘缓FFmpegFrameGrabber瀵硅薄 - FFmpegFrameGrabber grabber = new FFmpegFrameGrabber(rtspUrl); - grabber.start(); // 寮�濮嬫崟鑾� + grabber = FFmpegFrameGrabber.createDefault(rtspUrl); + grabber.start(); + Frame frame = grabber.grabImage(); // 鐩存帴鎹曡幏涓�甯� + if (frame != null) { + System.out.println("鎴愬姛鎹曡幏涓�甯�"); + // 灏咶rame杞崲涓篗at + OpenCVFrameConverter.ToMat converter = new OpenCVFrameConverter.ToMat(); + Mat mat = converter.convertToMat(frame); - Frame frame; - if ((frame = grabber.grabFrame()) != null) { - // 灏嗗抚杞崲涓哄浘鐗� - Java2DFrameConverter converter = new Java2DFrameConverter(); - BufferedImage image = converter.convert(frame); - File outputfile = new File(serverConfig.getUrl() + PlatformConfig.getUploadPath() + deviceId + IdUtils.fastSimpleUUID() + ".png"); - ImageIO.write(image, "png", outputfile); - String imgPath = outputfile.getAbsolutePath(); - System.out.println("Saved " + imgPath); - return imgPath; + imgUrl = workOrderNo + "_" + IdUtils.fastSimpleUUID() + ".png"; + // 鐢熸垚鍥剧墖璺緞 + String imgPath = PlatformConfig.getUploadPath() + "/" + imgUrl; + System.out.println("鍥剧墖淇濆瓨鍦板潃锛�" + imgPath); + imgUrl = Constants.RESOURCE_PREFIX + "/" + imgUrl; + // 淇濆瓨鍥剧墖 + opencv_imgcodecs.imwrite(imgPath, mat); + } else { + System.out.println("鏈崟鑾峰埌甯�"); } - grabber.stop(); // 鍋滄鎹曡幏 - grabber.release(); // 閲婃斁璧勬簮 - } catch (IOException e) { + } catch (FrameGrabber.Exception e) { e.printStackTrace(); + } finally { + if (grabber != null) { + try { + grabber.stop(); // 鍋滄鎹曡幏 + } catch (FrameGrabber.Exception e) { + e.printStackTrace(); + } + // 閫氬父涓嶉渶瑕佽皟鐢╮elease()锛屽洜涓簊top()浼氬鐞嗚祫婧愰噴鏀� + // grabber.release(); // 閲婃斁璧勬簮 + } } } + } else { + System.out.println("璇锋眰澶辫触锛岄敊璇爜锛�" + wvpResult.getCode()); } - return null; + System.out.println("鍥剧墖URL锛�" + imgUrl); + return imgUrl; } @Override @@ -708,6 +726,7 @@ public void updateImgById(Integer workOrderId, String imgPath) { new LambdaUpdateChainWrapper<>(baseMapper) .eq(WorkOrder::getId, workOrderId) - .set(WorkOrder::getYwCheckResult, imgPath); + .set(WorkOrder::getYwCheckResult, imgPath) + .update(); } } -- Gitblit v1.8.0