|
|
@@ -7,16 +7,6 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
|
import com.qiwenshare.common.util.DateUtil;
|
|
|
import com.qiwenshare.common.util.MimeUtils;
|
|
|
-import com.qiwenshare.common.util.security.SessionUtil;
|
|
|
-import vip.xiaonuo.disk.service.IFiletransferService;
|
|
|
-import vip.xiaonuo.disk.component.FileDealComp;
|
|
|
-import vip.xiaonuo.disk.domain.*;
|
|
|
-import vip.xiaonuo.disk.dto.file.DownloadFileDTO;
|
|
|
-import vip.xiaonuo.disk.dto.file.PreviewDTO;
|
|
|
-import vip.xiaonuo.disk.dto.file.UploadFileDTO;
|
|
|
-import vip.xiaonuo.disk.io.QiwenFile;
|
|
|
-import vip.xiaonuo.disk.mapper.*;
|
|
|
-import vip.xiaonuo.disk.vo.file.UploadFileVo;
|
|
|
import com.qiwenshare.ufop.constant.StorageTypeEnum;
|
|
|
import com.qiwenshare.ufop.constant.UploadFileStatusEnum;
|
|
|
import com.qiwenshare.ufop.exception.operation.DownloadException;
|
|
|
@@ -37,6 +27,15 @@ import org.apache.commons.io.IOUtils;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
+import vip.xiaonuo.disk.component.FileDealComp;
|
|
|
+import vip.xiaonuo.disk.domain.*;
|
|
|
+import vip.xiaonuo.disk.dto.file.DownloadFileDTO;
|
|
|
+import vip.xiaonuo.disk.dto.file.PreviewDTO;
|
|
|
+import vip.xiaonuo.disk.dto.file.UploadFileDTO;
|
|
|
+import vip.xiaonuo.disk.io.QiwenFile;
|
|
|
+import vip.xiaonuo.disk.mapper.*;
|
|
|
+import vip.xiaonuo.disk.service.IFiletransferService;
|
|
|
+import vip.xiaonuo.disk.vo.file.UploadFileVo;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
import javax.servlet.http.HttpServletRequest;
|
|
|
@@ -84,7 +83,7 @@ public class FiletransferService implements IFiletransferService {
|
|
|
public static Executor exec = Executors.newFixedThreadPool(20);
|
|
|
|
|
|
@Override
|
|
|
- public UploadFileVo uploadFileSpeed(UploadFileDTO uploadFileDTO) {
|
|
|
+ public UploadFileVo uploadFileSpeed(String userId,UploadFileDTO uploadFileDTO) {
|
|
|
UploadFileVo uploadFileVo = new UploadFileVo();
|
|
|
Map<String, Object> param = new HashMap<>();
|
|
|
param.put("identifier", uploadFileDTO.getIdentifier());
|
|
|
@@ -101,7 +100,7 @@ public class FiletransferService implements IFiletransferService {
|
|
|
|
|
|
if (list != null && !list.isEmpty()) {
|
|
|
FileBean file = list.get(0);
|
|
|
- UserFile userFile = new UserFile(qiwenFile, SessionUtil.getUserId(), file.getFileId());
|
|
|
+ UserFile userFile = new UserFile(qiwenFile, userId, file.getFileId());
|
|
|
|
|
|
try {
|
|
|
userFileMapper.insert(userFile);
|
|
|
@@ -114,7 +113,7 @@ public class FiletransferService implements IFiletransferService {
|
|
|
if (relativePath.contains("/")) {
|
|
|
QiwenFile finalQiwenFile = qiwenFile;
|
|
|
exec.execute(()->{
|
|
|
- fileDealComp.restoreParentFilePath(finalQiwenFile, SessionUtil.getUserId());
|
|
|
+ fileDealComp.restoreParentFilePath(finalQiwenFile, userId);
|
|
|
});
|
|
|
|
|
|
}
|
|
|
@@ -139,7 +138,7 @@ public class FiletransferService implements IFiletransferService {
|
|
|
uploadTask.setFileName(qiwenFile.getNameNotExtend());
|
|
|
uploadTask.setFilePath(qiwenFile.getParent());
|
|
|
uploadTask.setExtendName(qiwenFile.getExtendName());
|
|
|
- uploadTask.setUserId(SessionUtil.getUserId());
|
|
|
+ uploadTask.setUserId(userId);
|
|
|
uploadTaskMapper.insert(uploadTask);
|
|
|
}
|
|
|
}
|