From 2c405f34c9bc32936957e45d1c38c55f5696fa46 Mon Sep 17 00:00:00 2001 From: zhangnaisong <2434969829@qq.com> Date: 星期四, 19 十月 2023 09:34:16 +0800 Subject: [PATCH] 三一车辆模型url更改提交 --- ard-work/src/main/java/com/ruoyi/media/service/impl/VtduServiceImpl.java | 59 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 58 insertions(+), 1 deletions(-) diff --git a/ard-work/src/main/java/com/ruoyi/media/service/impl/VtduServiceImpl.java b/ard-work/src/main/java/com/ruoyi/media/service/impl/VtduServiceImpl.java index ebf5978..05cc175 100644 --- a/ard-work/src/main/java/com/ruoyi/media/service/impl/VtduServiceImpl.java +++ b/ard-work/src/main/java/com/ruoyi/media/service/impl/VtduServiceImpl.java @@ -1,13 +1,25 @@ package com.ruoyi.media.service.impl; +import java.util.HashMap; import java.util.List; +import java.util.Map; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.common.utils.DateUtils; +import com.ruoyi.common.utils.SecurityUtils; +import com.ruoyi.common.utils.StringUtils; import com.ruoyi.common.utils.uuid.IdUtils; +import com.ruoyi.media.service.IMediaService; +import com.ruoyi.utils.forest.MediaClient; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import com.ruoyi.media.mapper.VtduMapper; import com.ruoyi.media.domain.Vtdu; import com.ruoyi.media.service.IVtduService; + +import javax.annotation.Resource; /** * 娴佸獟浣撶鐞哠ervice涓氬姟灞傚鐞� @@ -16,9 +28,12 @@ * @date 2023-08-29 */ @Service +@Slf4j public class VtduServiceImpl implements IVtduService { - @Autowired + @Resource private VtduMapper vtduMapper; + @Resource + private IMediaService mediaService; /** * 鏌ヨ娴佸獟浣撶鐞� @@ -50,6 +65,17 @@ */ @Override public int insertVtdu(Vtdu vtdu) { + log.info("娴佸獟浣撱��" + vtdu.getName() + "銆戦�氶亾娣诲姞"); + Map<String, String> map = mediaService.addPath(vtdu.getName(), vtdu.getRtspSource(), vtdu.getMode(), vtdu.getIsCode()); + vtdu.setRtspUrl(map.get("rtspUrl")); + vtdu.setRtmpUrl(map.get("rtmpUrl")); + vtdu.setWebrtcUrl(map.get("webrtcUrl")); + + vtdu.setName(vtdu.getName()); + vtdu.setRtspSource(vtdu.getRtspSource()); + vtdu.setIsCode(vtdu.getIsCode()); + vtdu.setMode(vtdu.getMode()); + vtdu.setCreateTime(DateUtils.getNowDate()); return vtduMapper.insertVtdu(vtdu); } @@ -61,6 +87,17 @@ */ @Override public int updateVtdu(Vtdu vtdu) { + + log.info("娴佸獟浣撱��" + vtdu.getName() + "銆戦�氶亾鏇存柊"); + Map<String, String> map = mediaService.editPath(vtdu.getName(), vtdu.getRtspSource(), vtdu.getMode(), vtdu.getIsCode()); + vtdu.setName(vtdu.getName()); + vtdu.setRtspSource(vtdu.getRtspSource()); + vtdu.setIsCode(vtdu.getIsCode()); + vtdu.setMode(vtdu.getMode()); + vtdu.setRtspUrl(map.get("rtspUrl")); + vtdu.setRtmpUrl(map.get("rtmpUrl")); + vtdu.setWebrtcUrl(map.get("webrtcUrl")); + vtdu.setUpdateTime(DateUtils.getNowDate()); return vtduMapper.updateVtdu(vtdu); } @@ -72,6 +109,7 @@ */ @Override public int deleteVtduByNames(String[] names) { + mediaService.removePath(names); return vtduMapper.deleteVtduByNames(names); } @@ -85,4 +123,23 @@ public int deleteVtduByName(String name) { return vtduMapper.deleteVtduByName(name); } + + /** + * 鍒犻櫎娴佸獟浣撶鐞嗕俊鎭� + * + * @param cameraId 鐩告満ID + * @return 缁撴灉 + */ + @Override + public int deleteVtduByCameraId(String cameraId) { + Vtdu vtdu = new Vtdu(); + vtdu.setCameraId(cameraId); + List<Vtdu> vtdus = vtduMapper.selectVtduList(vtdu); + if (vtdus.size() > 0) { + for (Vtdu v : vtdus) { + mediaService.removePath(v.getName()); + } + } + return vtduMapper.deleteVtduByCameraId(cameraId); + } } -- Gitblit v1.9.3