浏览代码

边拍边上传

dengsixing 2 周之前
父节点
当前提交
02ca66ffb6
共有 1 个文件被更改,包括 2 次插入6 次删除
  1. 2 6
      src/main/java/com/fdkankan/contro/mq/listener/UploadShootingListener.java

+ 2 - 6
src/main/java/com/fdkankan/contro/mq/listener/UploadShootingListener.java

@@ -2,12 +2,9 @@ package com.fdkankan.contro.mq.listener;
 
 import cn.hutool.core.collection.CollUtil;
 import com.alibaba.fastjson.JSONObject;
-import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.fdkankan.common.constant.CommonStatus;
 import com.fdkankan.common.constant.CommonSuccessStatus;
 import com.fdkankan.common.constant.SceneStatus;
-import com.fdkankan.common.util.FileUtils;
-import com.fdkankan.contro.constant.RedisConstants;
 import com.fdkankan.contro.entity.*;
 import com.fdkankan.contro.service.*;
 import com.fdkankan.contro.util.HttpUtilExt;
@@ -114,10 +111,9 @@ public class UploadShootingListener {
             }
             mqProducer.sendByWorkQueue("laser-preview-scene-handler", playLoad);
 
-            String batchKey = RedisConstants.BATCH_ID_UPLOAD_SHOOTING.replace("@uuid@", uuid).replace("@index@", String.valueOf(index));
-            redisUtil.del(batchKey);
+//            String batchKey = RedisConstants.BATCH_ID_UPLOAD_SHOOTING.replace("@uuid@", uuid).replace("@index@", String.valueOf(index));
+//            redisUtil.del(batchKey);
 
-            origFileUploadBatchService.update(new LambdaUpdateWrapper<OrigFileUploadBatch>().set(OrigFileUploadBatch::getStatus, 3).eq(OrigFileUploadBatch::getBatchId,batchId));
 
         }catch (Exception e){
             log.error("场景预览文件处理出错, num:{}", num, e);