Преглед на файлове

增加接口:记录app触发上传场景次数

dengsixing преди 1 година
родител
ревизия
346c2cac2b

+ 5 - 0
src/main/java/com/fdkankan/contro/service/ISceneUploadCountService.java

@@ -19,4 +19,9 @@ public interface ISceneUploadCountService extends IService<SceneUploadCount> {
 
     void increSceneUploadCount(SceneUploadCountParamVO param);
 
+    void resetCountByUuid(String uuid);
+
+    SceneUploadCount getByUUid(String uuid);
+
+
 }

+ 6 - 0
src/main/java/com/fdkankan/contro/service/impl/SceneFileBuildServiceImpl.java

@@ -197,6 +197,8 @@ public class SceneFileBuildServiceImpl extends ServiceImpl<ISceneFileBuildMapper
     private IntermitSceneService intermitSceneService;
     @Autowired
     private ISceneRebuildLogService sceneRebuildLogService;
+    @Autowired
+    private ISceneUploadCountService sceneUploadCountService;
 
     @Override
     public SceneFileBuild findByFileId(String fileId) {
@@ -628,6 +630,8 @@ public class SceneFileBuildServiceImpl extends ServiceImpl<ISceneFileBuildMapper
             folderName = fileBuild.getUnicode();
             redisUtil.set(String.format(RedisConstants.FILEID_FOLDER_BUILD, fileId), folderName,2 * 24 * 60 * 60);
         }
+        sceneUploadCountService.resetCountByUuid(folderName);
+
         StringBuilder prefixBuffer = new StringBuilder(mac).append(File.separator).append(fileId).append(File.separator).append(folderName).append(File.separator);
 
         String buildType = "V2";
@@ -777,6 +781,8 @@ public class SceneFileBuildServiceImpl extends ServiceImpl<ISceneFileBuildMapper
             redisUtil.set(String.format(RedisConstants.FILEID_FOLDER_BUILD, fileId), folderName);
         }
 
+        sceneUploadCountService.resetCountByUuid(folderName);
+
         //云目录
         StringBuilder prefixBuffer = new StringBuilder(mac).append(File.separator).append(fileId).append(File.separator).append(folderName).append(File.separator);
 

+ 16 - 1
src/main/java/com/fdkankan/contro/service/impl/SceneUploadCountServiceImpl.java

@@ -39,7 +39,7 @@ public class SceneUploadCountServiceImpl extends ServiceImpl<ISceneUploadCountMa
             throw new BusinessException(CameraConstant.FAILURE_6003);
         }
 
-        SceneUploadCount sceneUploadCount = this.getOne(new LambdaQueryWrapper<SceneUploadCount>().eq(SceneUploadCount::getUuid, uuid));
+        SceneUploadCount sceneUploadCount = this.getByUUid(uuid);
         if(Objects.isNull(sceneUploadCount)){
             sceneUploadCount = new SceneUploadCount();
             sceneUploadCount.setUuid(uuid);
@@ -51,4 +51,19 @@ public class SceneUploadCountServiceImpl extends ServiceImpl<ISceneUploadCountMa
 
         this.saveOrUpdate(sceneUploadCount);
     }
+
+    @Override
+    public void resetCountByUuid(String uuid) {
+        SceneUploadCount sceneUploadCount = this.getByUUid(uuid);
+        if(Objects.isNull(sceneUploadCount)){
+            return;
+        }
+        sceneUploadCount.setCount(0);
+        this.updateById(sceneUploadCount);
+    }
+
+    @Override
+    public SceneUploadCount getByUUid(String uuid) {
+        return this.getOne(new LambdaQueryWrapper<SceneUploadCount>().eq(SceneUploadCount::getUuid, uuid));
+    }
 }