zgyw.git - Gitblit

			@@ -37,10 +37,7 @@
			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;
			import enumeration.general.WorkOrderStatusEnum;
			import enumeration.general.*;
			import lombok.RequiredArgsConstructor;
			import lombok.extern.slf4j.Slf4j;
			import org.apache.commons.lang3.ObjectUtils;
			@@ -73,7 +70,6 @@
			@RequiredArgsConstructor
			public class WorkOrderServiceImpl extends ServiceImpl<WorkOrderMapper, WorkOrder> implements WorkOrderService {

			private final WorkOrderMapper workOrderMapper;
			private final YwPointService ywPointService;
			private final WorkOrderAuditingRecordMapper workOrderAuditingRecordMapper;
			private final WorkOrderAuditingRecordService workOrderAuditingRecordService;
			@@ -82,9 +78,8 @@
			private final WorkOrderDistributeRecordMapper workOrderDistributeRecordMapper;
			private final WorkOrderErrorTypeServiceImpl workOrderErrorTypeService;
			private final SysConfigMapper configMapper;
			private final ServerConfig serverConfig;
			private final ReportMapper reportMapper;
			private final SysDictDataMapper dictDataMapper;
			private final WorkOrderCheckImgMapper workOrderCheckImgMapper;

			@Value("${rtsp.server:http://127.0.0.1:7788}")
			private String rtspServer;
			@@ -402,7 +397,7 @@
			List<WorkOrderYwConditionRecordVO> ywConditionList = workOrderYwConditionRecordMapper.selectYwConditionByYwId(workOrderNo);
			ywConditionList.stream().forEach(item -> {
			if (Objects.nonNull(item.getSysMsg()) && item.getSysMsg()) {
			item.setCommitUserName("系统消息");
			item.setUnitName("系统消息");
			}
			});
			return ywConditionList;
			@@ -667,7 +662,25 @@

			@Override
			public List<WorkOrderRegionVO> workOrderRegion(DashboardQuery dashboardQuery) {
			return baseMapper.workOrderRegion(dashboardQuery);
			//初始化所有区域数据
			List<WorkOrderRegionVO> vos = new ArrayList<>();
			for (AreaDeptEnum value : AreaDeptEnum.values()) {
			WorkOrderRegionVO vo = new WorkOrderRegionVO();
			vo.setArea(value.getName());
			vo.setDoneNum(0);
			vo.setTodoNum(0);
			vos.add(vo);
			}
			List<WorkOrderRegionVO> workOrderRegionVOS = baseMapper.workOrderRegion(dashboardQuery);
			for (WorkOrderRegionVO vo : vos) {
			for (WorkOrderRegionVO workOrder : workOrderRegionVOS) {
			//赋值
			if(vo.getArea().equals(workOrder.getArea())){
			BeanUtils.copyProperties(workOrder,vo);
			}
			}
			}
			return vos;
			}


			@@ -685,6 +698,8 @@
			FFmpegFrameGrabber grabber = null;
			try {
			grabber = FFmpegFrameGrabber.createDefault(rtspUrl);
			//设置10s超时
			grabber.setTimeout(10000);
			grabber.start();
			Frame frame = grabber.grabImage(); // 直接捕获一帧
			if (frame != null) {
			@@ -722,6 +737,67 @@
			}
			System.out.println("图片URL：" + imgUrl);
			return imgUrl;
			}

			@Override
			public void saveFrameImgByDevice(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);
			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 = FFmpegFrameGrabber.createDefault(rtspUrl);
			//设置10s超时
			grabber.setTimeout(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();
			}
			// 通常不需要调用release()，因为stop()会处理资源释放
			// grabber.release(); // 释放资源
			}
			}
			}
			} else {
			System.out.println("请求失败，错误码：" + wvpResult.getCode());
			}
			System.out.println("图片URL：" + imgUrl);
			if (StringUtils.hasText(imgUrl)) {
			WorkOrderCheckImg img = new WorkOrderCheckImg();
			img.setWorkOrderNo(workOrderNo);
			img.setImgUrl(imgUrl);
			img.setCreateTime(new Date());
			workOrderCheckImgMapper.insert(img);
			}
			}

			@Override
			@@ -791,6 +867,13 @@
			List<SysDictData> errorList = workOrderErrorTypeService.getBaseMapper().getErrorList(workOrder.getWorkOrderNo());
			List<String> errList = errorList.stream().map(SysDictData::getDictLabel).collect(Collectors.toList());
			workOrder.setErrorTypeList(errList);
			// 检测图片
			List<WorkOrderCheckImg> imgList = new LambdaQueryChainWrapper<>(workOrderCheckImgMapper)
			.eq(WorkOrderCheckImg::getWorkOrderNo, workOrderNo)
			.orderByDesc(WorkOrderCheckImg::getCreateTime)
			.last("limit 20")
			.list();
			workOrder.setImgList(imgList);
			return Result.ok().data(workOrder);
			}
			}