| | |
|---|
| | | 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; |
|---|
| | |
|---|
| | | * @author zhibing.pu |
|---|
| | | * @Date 2025/3/24 17:50 |
|---|
| | | */ |
|---|
| | | @Slf4j |
|---|
| | | @RestController |
|---|
| | | @RequestMapping("/order") |
|---|
| | | public class OrderController { |
|---|
| | |
|---|
| | | 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()); |
|---|
| | | //手动加一次状态数据，避免定时任务结束任务线程 |
|---|
| | |
|---|
| | | resp.setServerPort(flvHttpPort); |
|---|
| | | return R.ok(resp); |
|---|
| | | } |
|---|
| | | return R.fail(startupAckVoR.getMsg()); |
|---|
| | | log.error("获取视频失败：{}", startupAckVoR.getMsg()); |
|---|
| | | return R.fail("获取视频失败"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | public void live_flv(String input, Integer id){ |
|---|
| | | String url = "rtsp://" + flvIp + ":" + flvRtmpPort + "/flv/" + id; |
|---|
| | | String url = "rtmp://" + flvIp + ":" + flvRtmpPort + "/flv/" + id; |
|---|
| | | //执行拉流和推流 |
|---|
| | | ExecutorService executorService = new ThreadPoolExecutor(1, 1, |
|---|
| | | 0L, TimeUnit.MILLISECONDS, |
|---|
