From 5e4c0666f6d0d91cc4cf2263e42c7f06505625c7 Mon Sep 17 00:00:00 2001
From: aijinhui <aijinhui>
Date: 星期六, 21 十月 2023 15:26:29 +0800
Subject: [PATCH] 入栏

---
 ard-work/src/main/java/com/ruoyi/media/service/impl/VtduServiceImpl.java |   61 +++++++++++++++++++++++++++++-
 1 files changed, 58 insertions(+), 3 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..ee991af 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,17 @@
 package com.ruoyi.media.service.impl;
 
 import java.util.List;
+import java.util.Map;
 
-import com.ruoyi.common.utils.uuid.IdUtils;
-import org.springframework.beans.factory.annotation.Autowired;
+import com.ruoyi.common.utils.DateUtils;
+import com.ruoyi.media.service.IMediaService;
+import lombok.extern.slf4j.Slf4j;
 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 +20,12 @@
  * @date 2023-08-29
  */
 @Service
+@Slf4j(topic = "sdk")
 public class VtduServiceImpl implements IVtduService {
-    @Autowired
+    @Resource
     private VtduMapper vtduMapper;
+    @Resource
+    private IMediaService mediaService;
 
     /**
      * 鏌ヨ娴佸獟浣撶鐞�
@@ -28,6 +35,7 @@
      */
     @Override
     public Vtdu selectVtduByName(String name) {
+
         return vtduMapper.selectVtduByName(name);
     }
 
@@ -50,6 +58,17 @@
      */
     @Override
     public int insertVtdu(Vtdu vtdu) {
+        log.debug("娴佸獟浣撱��" + 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 +80,17 @@
      */
     @Override
     public int updateVtdu(Vtdu vtdu) {
+
+        log.debug("娴佸獟浣撱��" + 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 +102,10 @@
      */
     @Override
     public int deleteVtduByNames(String[] names) {
+        for (String name : names) {
+            log.debug("娴佸獟浣撱��" + name + "銆戦�氶亾鍒犻櫎");
+        }
+        mediaService.removePath(names);
         return vtduMapper.deleteVtduByNames(names);
     }
 
@@ -83,6 +117,27 @@
      */
     @Override
     public int deleteVtduByName(String name) {
+        log.debug("娴佸獟浣撱��" + name + "銆戦�氶亾鍒犻櫎");
+        mediaService.removePath(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