zgyw.git - Gitblit

			@@ -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;
			@@ -157,6 +160,7 @@
			ywRecord.setCommitUser(1);
			ywRecord.setYwCondition("故障类型更新，工单状态调整为待处理");
			ywRecord.setCreateTime(new Date());
			ywRecord.setSysMsg(Boolean.TRUE);
			willAddMsg.add(ywRecord);
			}
			} else {
			@@ -300,7 +304,7 @@
			baseMapper.updateById(workOrder);
			// 添加一条审核记录
			WorkOrderAuditingRecord workOrderAuditingRecord = new WorkOrderAuditingRecord();
			workOrderAuditingRecord.setWorkOrderId(workOrder.getId());
			workOrderAuditingRecord.setWorkOrderNo(workOrder.getWorkOrderNo());
			workOrderAuditingRecord.setAuditingUser(SecurityUtils.getLoginUser().getUserId().intValue());
			workOrderAuditingRecord.setResult(form.getAuditingResult().getDesc());
			workOrderAuditingRecord.setRemark(form.getAuditingRemark());
			@@ -331,18 +335,18 @@
			if (list.isEmpty()) {
			return Result.error("没有工单可以审核");
			}
			List<Integer> ids = list.stream().map(WorkOrder::getId).collect(Collectors.toList());
			List<String> workOrderNoList = list.stream().map(WorkOrder::getWorkOrderNo).collect(Collectors.toList());
			List<String> serialNumbers = list.stream().map(WorkOrder::getSerialNumber).toList();
			// 工单状态
			LambdaUpdateWrapper<WorkOrder> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
			lambdaUpdateWrapper.in(WorkOrder::getId, ids);
			lambdaUpdateWrapper.in(WorkOrder::getWorkOrderNo, workOrderNoList);
			lambdaUpdateWrapper.set(WorkOrder::getStatus, form.getAuditingResult());
			baseMapper.update(lambdaUpdateWrapper);
			// 添加多条审核记录
			List<WorkOrderAuditingRecord> workOrderAuditingRecords = new ArrayList<>();
			for (Integer id : ids) {
			for (String workOrderNo : workOrderNoList) {
			WorkOrderAuditingRecord workOrderAuditingRecord = new WorkOrderAuditingRecord();
			workOrderAuditingRecord.setWorkOrderId(id);
			workOrderAuditingRecord.setWorkOrderNo(workOrderNo);
			workOrderAuditingRecord.setAuditingUser(SecurityUtils.getLoginUser().getUserId().intValue());
			workOrderAuditingRecord.setResult(form.getAuditingResult().getDesc());
			workOrderAuditingRecord.setRemark(form.getAuditingRemark());
			@@ -390,8 +394,8 @@
			}

			@Override
			public Result selectYwConditionByYwId(Integer id) {
			List<WorkOrderYwConditionRecordVO> ywConditionList = workOrderYwConditionRecordMapper.selectYwConditionByYwId(id);
			public Result selectYwConditionByYwId(String workOrderNo) {
			List<WorkOrderYwConditionRecordVO> ywConditionList = workOrderYwConditionRecordMapper.selectYwConditionByYwId(workOrderNo);
			ywConditionList.stream().forEach(item -> {
			if (Objects.nonNull(item.getSysMsg()) && item.getSysMsg()) {
			item.setCommitUserName("系统消息");
			@@ -401,10 +405,10 @@
			}

			@Override
			public Result selectYwAuditingListByYwId(String id) {
			public Result selectYwAuditingListByYwId(String workOrderNo) {
			return Result.ok().data(
			new LambdaQueryChainWrapper<>(workOrderAuditingRecordMapper)
			.eq(WorkOrderAuditingRecord::getWorkOrderId, id)
			.eq(WorkOrderAuditingRecord::getWorkOrderNo, workOrderNo)
			.orderByAsc(WorkOrderAuditingRecord::getCreateTime)
			.list());
			}
			@@ -660,38 +664,56 @@


			@Override
			public String getFrameImgByDevice(String deviceId, String channelId) {
			String url = String.format(this.rtspServer + "/start/%s/%s", deviceId, 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);
			WVPResult wvpResult = JSON.parseObject(result, WVPResult.class);
			if (0 == wvpResult.getCode()) {
			StreamContent data = (StreamContent) wvpResult.getData();
			String rtspUrl = data.getRtsp();
			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 {
			// 创建FFmpegFrameGrabber对象
			FFmpegFrameGrabber grabber = new FFmpegFrameGrabber(rtspUrl);
			grabber.start(); // 开始捕获
			grabber = FFmpegFrameGrabber.createDefault(rtspUrl);
			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);

			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();
			}
			// 通常不需要调用release()，因为stop()会处理资源释放
			// grabber.release(); // 释放资源
			}
			}
			}
			} else {
			System.out.println("请求失败，错误码：" + wvpResult.getCode());
			}
			return null;
			System.out.println("图片URL：" + imgUrl);
			return imgUrl;
			}

			@Override
			@@ -704,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();
			}
			}