计算完毕通知删除场景v3版本目录

4dkankan-center-scene/src/main/java/com/fdkankan/scene/vo/DeleteFileParamVO.java

@@ -20,7 +20,7 @@ import lombok.NoArgsConstructor;
 @Builder
 @NoArgsConstructor
 @AllArgsConstructor
-public class DeleteFileParamVO{
+public class  DeleteFileParamVO{
 
     /**
      * 场景码

4dkankan-task/src/main/java/com/fdkankan/task/listener/MqListener.java

@@ -24,7 +24,8 @@ public class MqListener {
      * @throws Exception
      */
     @RabbitListener(
-            queues = "QUEUE_DELETE_S3_FILE", concurrency = "3"
+            queues = "QUEUE_DELETE_S3_FILE",
+            concurrency = "${maxThread.scene.deleteS3File}"
     )
     public void buildScenePreHandler(Channel channel, Message message) throws Exception {
         String num = new String(message.getBody(), StandardCharsets.UTF_8);

4dkankan-task/src/main/java/com/fdkankan/task/mapper/IScenePlusMapper.java

@@ -15,4 +15,6 @@ import org.apache.ibatis.annotations.Mapper;
 @Mapper
 public interface IScenePlusMapper extends BaseMapper<ScenePlus> {
 
+    ScenePlus selectDeleteScene(String num);
+
 }

4dkankan-task/src/main/java/com/fdkankan/task/service/IScenePlusService.java

@@ -15,6 +15,8 @@ public interface IScenePlusService extends IService<ScenePlus> {
 
     ScenePlus getScenePlusByNum(String num);
 
+    ScenePlus getScenePlusByNumWithDelete(String num);
+
     void deleteV3DirHandler(String num);
 
     void deleteSceneHandler(String num);

4dkankan-task/src/main/java/com/fdkankan/task/service/impl/ScenePlusServiceImpl.java

@@ -42,6 +42,11 @@ public class ScenePlusServiceImpl extends ServiceImpl<IScenePlusMapper, ScenePlu
     private RedisUtil redisUtil;
 
     @Override
+    public ScenePlus getScenePlusByNumWithDelete(String num) {
+        return null;
+    }
+
+    @Override
     public ScenePlus getScenePlusByNum(String num) {
         return this.getOne(new LambdaQueryWrapper<ScenePlus>().eq(ScenePlus::getNum, num));
     }
@@ -109,7 +114,7 @@ public class ScenePlusServiceImpl extends ServiceImpl<IScenePlusMapper, ScenePlu
         try {
             log.info("删除场景全部数据开始,num：{}", num);
 
-            ScenePlus scenePlus = this.getScenePlusByNum(num);
+            ScenePlus scenePlus = this.baseMapper.selectDeleteScene(num);
             ScenePlusExt scenePlusExt = scenePlusExtService.getScenePlusExtByPlusId(scenePlus.getId());
             String bucket = scenePlusExt.getYunFileBucket();
 

4dkankan-task/src/main/resources/mapper/task/ScenePlusMapper.xml

@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.fdkankan.task.mapper.IScenePlusMapper">
+
+    <select id="selectDeleteScene" resultType="com.fdkankan.task.entity.ScenePlus">
+        select * from t_scene_plus t where t.num=#{num}
+    </select>
+
+</mapper>