From 1ee76c252f2dbba62e0ec34cccf9eaac51de9083 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期三, 23 七月 2025 16:25:23 +0800
Subject: [PATCH] 修改bug
---
ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/OrderController.java | 46 ++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 42 insertions(+), 4 deletions(-)
diff --git a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/OrderController.java b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/OrderController.java
index 0b6870c..ff94854 100644
--- a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/OrderController.java
+++ b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/OrderController.java
@@ -21,7 +21,10 @@
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
import org.apache.poi.ss.usermodel.Workbook;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -36,11 +39,13 @@
import java.time.ZoneOffset;
import java.time.format.DateTimeFormatter;
import java.util.List;
+import java.util.concurrent.TimeUnit;
/**
* @author zhibing.pu
* @Date 2025/3/24 17:50
*/
+@Slf4j
@RestController
@RequestMapping("/order")
public class OrderController {
@@ -62,6 +67,27 @@
@Resource
private PlaybackMsgClient playbackMsgClient;
+
+ @Resource
+ private RedisTemplate redisTemplate;
+
+ @Value("${live.hls.output-path}")
+ private String hlsOutputPath;
+
+ @Value("${live.hls.ip}")
+ private String hlsIp;
+
+ @Value("${live.hls.port}")
+ private Integer hlsPort;
+
+ @Value("${live.flv.ip}")
+ private String flvIp;
+
+ @Value("${live.flv.rtmp-port}")
+ private Integer flvRtmpPort;
+
+ @Value("${live.flv.http-port}")
+ private Integer flvHttpPort;
@GetMapping("/getOrderList")
@@ -120,6 +146,7 @@
order.setDrivingLicenseNumber(driver.getDrivingLicenseNumber());
}
order.setVehicleNumber(car.getVehicleNumber());
+ order.setDeviceId(car.getDeviceId());
order.setEnterpriseName(enterprise.getName());
return R.ok(order);
}
@@ -152,9 +179,11 @@
public R<RealVideoResp> getOrderMonitoring(Integer id) {
Order order = orderService.getById(id);
if (null == order) {
- return R.fail("失败");
+ return R.fail("发起实时音视频失败，可能是车辆离线导致");
}
Car car = carService.getById(order.getCarId());
+ //手动加一次状态数据，避免定时任务结束任务线程
+ redisTemplate.opsForValue().set("live:" + order.getCarId(), true, 1, TimeUnit.MINUTES);
Enterprise enterprise = enterpriseService.getById(car.getEnterpriseId());
LocalDateTime dateTime = LocalDateTime.parse(order.getOrderTime(), DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
long startTime = dateTime.toEpochSecond(ZoneOffset.ofHours(8));
@@ -164,10 +193,19 @@
if (200 == startupAckVoR.getCode()) {
UPPlaybackMsgStartupAckVo data = startupAckVoR.getData();
RealVideoResp resp = new RealVideoResp();
- resp.setServerIp(data.getServerIP());
- resp.setServerPort(data.getServerPort());
+ //执行拉流和推流
+// live_hls(data.getUrl(), car);
+// resp.setServerIp(hlsIp);
+// resp.setServerPort(hlsPort);
+ resp.setUrl(data.getUrl());
+// live_flv(data.getUrl(), car.getId());
+ resp.setServerIp(flvIp);
+ resp.setServerPort(flvHttpPort);
return R.ok(resp);
}
- return R.fail(startupAckVoR.getMsg());
+ log.error("获取视频失败：{}", startupAckVoR.getMsg());
+ return R.fail("发起实时音视频失败，可能是车辆离线导致");
}
+
+
}
--
Gitblit v1.7.1