update ObjectRepository

dfs-store/src/main/java/cn/reghao/dfs/store/db/repository/ObjectRepository.java

@@ -41,7 +41,6 @@ public class ObjectRepository {
     }
 
     @CacheEvict(cacheNames = "oss:store:objectMeta", key = "#fileMeta.objectName")
-    @Transactional(rollbackFor = Exception.class)
     public void deleteObject(FileMeta fileMeta) {
         String contentId = fileMeta.getContentId();
         List<FileMeta> list = fileMetaMapper.findByContentId(contentId);
@@ -49,14 +48,19 @@ public class ObjectRepository {
             DataBlock dataBlock = dataBlockMapper.findByContentId(contentId);
             String absolutePath = dataBlock.getAbsolutePath();
 
-            fileMetaMapper.delete(fileMeta);
-            dataBlockMapper.delete(dataBlock);
+            deleteObject(fileMeta, dataBlock);
             FileUtils.deleteQuietly(new File(absolutePath));
         } else {
             fileMetaMapper.delete(fileMeta);
         }
     }
 
+    @Transactional(rollbackFor = Exception.class)
+    public void deleteObject(FileMeta fileMeta, DataBlock dataBlock) {
+        fileMetaMapper.delete(fileMeta);
+        dataBlockMapper.delete(dataBlock);
+    }
+
     public void deleteByObjectId(String objectId) {
         FileMeta fileMeta = fileMetaMapper.findByObjectId(objectId);
         deleteObject(fileMeta);
@@ -66,6 +70,10 @@ public class ObjectRepository {
         objectIds.forEach(this::deleteByObjectId);
     }
 
+    public void updateObjectScope(int scope, List<String> objectIds) {
+        fileMetaMapper.updateScopeByObjectIds(scope, objectIds);
+    }
+
     public FileMeta getByObjectName(String objectName) {
         return fileMetaMapper.findByObjectName(objectName);
     }

dfs-store/src/main/java/cn/reghao/dfs/store/rpc/ObjectServiceImpl.java

@@ -69,8 +69,4 @@ public class ObjectServiceImpl implements ObjectService {
         String token = JwtUtil.createToken(ossPayload, expireAt, signKey);
         return new DownloadUrl(url1, token);
     }
-
-    public void setObjectScope(String objectId, int fileType) {
-
-    }
 }