Browse Source

录制视频继续录制

lyhzzz 3 years ago
parent
commit
266e203d2c

+ 1 - 1
src/main/java/com/fdkankan/fusion/service/ICaseNumService.java

@@ -22,7 +22,7 @@ public interface ICaseNumService extends IService<CaseNumEntity> {
 
     void addBatch(Integer caseId, List<SceneNumParam> sceneNumParam);
 
-    void deleteByCaseId(Integer caseId,Boolean rest);
+    void deleteByCaseId(Integer caseId);
 
     HashMap<Integer, List<String>> getTypeMap(Integer caseId);
 

+ 3 - 5
src/main/java/com/fdkankan/fusion/service/impl/CaseNumServiceImpl.java

@@ -60,7 +60,7 @@ public class CaseNumServiceImpl extends ServiceImpl<ICaseNumMapper, CaseNumEntit
     @Override
     public void addBatch(Integer caseId, List<SceneNumParam> sceneNumParam) {
 
-        this.deleteByCaseId(caseId,true);
+        this.deleteByCaseId(caseId);
 
         List<CaseNumEntity> newCaseNums = new ArrayList<>();
         List<Model> modelList = new ArrayList<>();
@@ -126,13 +126,11 @@ public class CaseNumServiceImpl extends ServiceImpl<ICaseNumMapper, CaseNumEntit
     }
 
     @Override
-    public void deleteByCaseId(Integer caseId,Boolean rest) {
+    public void deleteByCaseId(Integer caseId) {
         LambdaQueryWrapper<CaseNumEntity> wrapper = new LambdaQueryWrapper<>();
         wrapper.eq(CaseNumEntity::getCaseId,caseId);
         this.remove(wrapper);
-        if(!rest){
-            fusionNumService.deleteByCaseId(caseId);
-        }
+        fusionNumService.deleteByCaseId(caseId);
     }
 
     @Override

+ 1 - 1
src/main/java/com/fdkankan/fusion/service/impl/CaseServiceImpl.java

@@ -144,7 +144,7 @@ public class CaseServiceImpl extends ServiceImpl<ICaseMapper, CaseEntity> implem
             throw new BusinessException(ResultCode.MISSING_REQUIRED_PARAMETERS);
         }
         //删除关联的场景
-        caseNumService.deleteByCaseId(caseId,false);
+        caseNumService.deleteByCaseId(caseId);
 
         this.removeById(caseId);
     }

+ 16 - 5
src/main/java/com/fdkankan/fusion/service/impl/CaseVideoServiceImpl.java

@@ -19,11 +19,13 @@ import com.fdkankan.fusion.service.ICaseVideoFolderService;
 import com.fdkankan.fusion.service.ICaseVideoService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.fdkankan.redis.util.RedisUtil;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.web.multipart.MultipartFile;
 
+import java.io.File;
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.LinkedHashSet;
@@ -79,15 +81,22 @@ public class CaseVideoServiceImpl extends ServiceImpl<ICaseVideoMapper, CaseVide
         if(videoFolder == null){
             throw new BusinessException(ResultCode.FOLDER_NOT_EXIST);
         }
-        uploadService.deleteOssUrl(videoFolder.getVideoMergeUrl());
-        uploadService.deleteOssUrl(videoFolder.getVideoFolderCover());
+        String mergeVideoUrl = null;
+        if(StringUtils.isNotBlank(videoFolder.getVideoMergeUrl())){
+            uploadService.deleteOssUrl(videoFolder.getVideoMergeUrl());
+            mergeVideoUrl = videoFolder.getVideoMergeUrl().replace(queryPath,"/home/");
+            uploadToOssUtil.downFormAli(videoFolder.getVideoMergeUrl(),mergeVideoUrl);
+        }
+        if(StringUtils.isNotBlank(videoFolder.getVideoMergeUrl())){
+            uploadService.deleteOssUrl(videoFolder.getVideoFolderCover());
+        }
         this.deleteByFolderId(folderId);
         redisUtil.set(RedisKeyUtil.mergerVideoKey+videoFolder.getVideoFolderId(),"10");
-        runThread(files,videoFolder,this);
+        runThread(mergeVideoUrl,files,videoFolder,this);
         return videoFolder;
     }
 
-    private void runThread(MultipartFile[] files,CaseVideoFolder videoFolder,ICaseVideoService caseVideoService){
+    private void runThread(String mergeVideoUrl,MultipartFile[] files,CaseVideoFolder videoFolder,ICaseVideoService caseVideoService){
         new Runnable() {
             @Override
             public void run() {
@@ -121,7 +130,9 @@ public class CaseVideoServiceImpl extends ServiceImpl<ICaseVideoMapper, CaseVide
                     return;
                 }
                 redisUtil.set(RedisKeyUtil.mergerVideoKey+videoFolder.getVideoFolderId(),"20");
-
+                if(StringUtils.isNotBlank(mergeVideoUrl)){
+                    filePathSet.add(mergeVideoUrl);
+                }
                 String mergeLocalName = VideoUtil.mergeVideo(filePathSet, FilePath.VIDEO_LOCAL_PATH);
                 redisUtil.set(RedisKeyUtil.mergerVideoKey+videoFolder.getVideoFolderId(),"30");
                 if(mergeLocalName == null){

+ 1 - 1
src/main/java/com/fdkankan/fusion/service/impl/ModelServiceImpl.java

@@ -118,7 +118,7 @@ public class ModelServiceImpl extends ServiceImpl<IModelMapper, Model> implement
             throw e;
         }finally {
             if(newObjFile!=null){
-                newObjFile.deleteOnExit();
+                newObjFile.delete();
             }
         }