zgyw.git - Gitblit

			@@ -56,6 +56,13 @@
			import org.springframework.util.CollectionUtils;
			import org.springframework.util.StringUtils;

			import javax.swing.*;
			import java.io.IOException;
			import java.net.HttpURLConnection;
			import java.net.URL;
			import java.net.URLDecoder;
			import java.net.URLEncoder;
			import java.nio.charset.StandardCharsets;
			import java.text.SimpleDateFormat;
			import java.time.LocalDateTime;
			import java.time.ZoneId;
			@@ -293,14 +300,14 @@
			@Override
			public Result add(WorkOrderForm form) {
			//查redis今日工单数量
			int workOrderNum = 1;
			int workOrderNum = 0;
			//UUID作为value，保证上锁的线程自己解锁
			String requestId = IdUtils.fastSimpleUUID();
			boolean result = redisCache.acquireLock(RedisConstant.WORKORDER_NUM_LOCK, requestId, 10000);
			if (result) {
			//查今日工单量
			Object redisNum = redisCache.getCacheObject(RedisConstant.WORKORDER_NUM);
			workOrderNum = redisNum == null ? 1 : (Integer) redisNum;
			workOrderNum = redisNum == null ? 0 : (Integer) redisNum;
			workOrderNum++;
			redisCache.setCacheObject(RedisConstant.WORKORDER_NUM, workOrderNum);
			redisCache.releaseLock(RedisConstant.WORKORDER_NUM_LOCK, requestId);
			@@ -559,7 +566,7 @@
			.select(WorkOrder::getSerialNumber, WorkOrder::getWorkOrderNo)
			.eq(WorkOrder::getStatus, WorkOrderStatusEnum.WAIT_DISTRIBUTE)
			.eq(Objects.nonNull(data.getUnitId()), WorkOrder::getUnitId, data.getUnitId())
			.eq(WorkOrder::getErrorType, data.getErrorType())
			.in(WorkOrder::getErrorType, data.getErrorType())
			.between(WorkOrder::getCreateTime, data.getStart(), data.getEnd())
			.orderByDesc(WorkOrder::getCreateTime)
			.last("limit " + data.getFastNumLimit())
			@@ -621,6 +628,7 @@
			ywPointService.updateRecovery(serialNumberList, 1);
			return Result.ok("成功下发" + query.getWorkOrderNOList().size() + "条工单");
			} catch (Exception e) {
			System.out.println(e.getMessage());
			return Result.error("操作失败");
			} finally {
			distributeUnLock();
			@@ -755,26 +763,36 @@
			public synchronized 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);
			String imgUrl = null;
			if (wvpResult.getCode() == 0) {
			JSONObject data = (JSONObject) wvpResult.getData();
			String rtspUrl = data.getString("mp4"); // 取mp4地址
			if (0 == wvpResult.getCode()) {
			log.error("请求成功");
			StreamContent data = (StreamContent) wvpResult.getData();
			String rtspUrl = data.getRtsp();
			log.error("目标地址：" + rtspUrl);
			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"); // 设置捕获分析的最大字节
			//设置10s超时
			grabber.setTimeout(10000);
			FFmpegFrameGrabber grabber = FFmpegFrameGrabber.createDefault(rtspUrl);
			grabber.setOption("rtsp_transport", "tcp"); // 使用tcp的方式，不然会丢包很严重
			grabber.setImageWidth(960);
			grabber.setImageHeight(540);
			grabber.start();
			Frame frame = grabber.grabImage(); // 直接捕获一帧
			if (frame != null) {
			System.out.println("成功捕获一帧");
			// 将Frame转换为Mat
			OpenCVFrameConverter.ToMat converter = new OpenCVFrameConverter.ToMat();
			CanvasFrame canvasFrame = new CanvasFrame("正茂");// 创建窗口
			canvasFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);// 设置窗口关闭程序是否也跟随关闭
			canvasFrame.setAlwaysOnTop(true);

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

			//opencv_core.Mat
			Mat mat = converter.convertToMat(frame);

			imgUrl = workOrderNo + "_" + IdUtils.fastSimpleUUID() + ".png";
			@@ -782,27 +800,25 @@
			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) {

			ex++;
			try {
			grabber.stop(); // 停止捕获
			} catch (FrameGrabber.Exception e) {
			e.printStackTrace();
			Thread.sleep(1000);
			}
			catch (InterruptedException e)
			{
			e.printStackTrace();
			} // 1000毫秒刷新一次圖像
			}
			grabber.stop(); // 停止捕获
			grabber.release(); // 释放资源
			} catch (IOException e) {
			e.printStackTrace();
			}
			}
			} else {
			System.out.println("请求失败，错误码：" + wvpResult.getCode() + "--" + wvpResult.getMsg());
			}
			System.out.println("图片URL：" + imgUrl);
			return imgUrl;
			}